Uses of Class
com.hazelcast.jet.pipeline.JmsSinkBuilder

Packages that use JmsSinkBuilder

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of JmsSinkBuilder in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return JmsSinkBuilder

Modifier and Type	Method	Description
JmsSinkBuilder<T>	JmsSinkBuilder.connectionFn(FunctionEx<jakarta.jms.ConnectionFactory,jakarta.jms.Connection> connectionFn)	Sets the function which creates a connection given a connection factory.
JmsSinkBuilder<T>	JmsSinkBuilder.connectionParams(String username, String password)	Sets the connection parameters.
JmsSinkBuilder<T>	JmsSinkBuilder.destinationName(String destinationName)	Sets the name of the destination.
JmsSinkBuilder<T>	JmsSinkBuilder.exactlyOnce(boolean enable)	Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots.
static <T> JmsSinkBuilder<T>	Sinks.jmsQueueBuilder(SupplierEx<jakarta.jms.ConnectionFactory> factorySupplier)	Returns a builder object that offers a step-by-step fluent API to build a custom JMS queue sink for the Pipeline API.
static <T> JmsSinkBuilder<T>	Sinks.jmsTopicBuilder(SupplierEx<jakarta.jms.ConnectionFactory> factorySupplier)	Returns a builder object that offers a step-by-step fluent API to build a custom JMS topic sink for the Pipeline API.
JmsSinkBuilder<T>	JmsSinkBuilder.messageFn(BiFunctionEx<jakarta.jms.Session,T,jakarta.jms.Message> messageFn)	Sets the function which creates the message from the item.