Uses of Class
com.hazelcast.jet.pipeline.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<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.