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 and Description
JmsSinkBuilder<T>	JmsSinkBuilder.connectionFn(FunctionEx<javax.jms.ConnectionFactory,javax.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<javax.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<javax.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<javax.jms.Session,T,javax.jms.Message> messageFn) Sets the function which creates the message from the item.