Uses of Class
com.hazelcast.jet.pipeline.JmsSourceBuilder
Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of JmsSourceBuilder in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return JmsSourceBuilder Modifier and Type Method Description JmsSourceBuilder
JmsSourceBuilder. connectionFn(FunctionEx<? super javax.jms.ConnectionFactory,? extends javax.jms.Connection> connectionFn)
Sets the function which creates the connection using the connection factory.JmsSourceBuilder
JmsSourceBuilder. connectionParams(String username, String password)
Sets the connection parameters.JmsSourceBuilder
JmsSourceBuilder. consumerFn(FunctionEx<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn)
Sets the function which creates the message consumer from session.JmsSourceBuilder
JmsSourceBuilder. destinationName(String destinationName)
Sets the name of the destination (name of the topic or queue).static JmsSourceBuilder
Sources. jmsQueueBuilder(SupplierEx<? extends javax.jms.ConnectionFactory> factorySupplier)
Returns a builder object that offers a step-by-step fluent API to build a custom JMSStreamSource
for the Pipeline API.static JmsSourceBuilder
Sources. jmsTopicBuilder(SupplierEx<? extends javax.jms.ConnectionFactory> factorySupplier)
Returns a builder object that offers a step-by-step fluent API to build a custom JMSStreamSource
for the Pipeline API.JmsSourceBuilder
JmsSourceBuilder. maxGuarantee(ProcessingGuarantee guarantee)
Sets the maximum processing guarantee for the source.JmsSourceBuilder
JmsSourceBuilder. messageIdFn(FunctionEx<? super javax.jms.Message,?> messageIdFn)
Configures the function to extract IDs from the messages, if exactly-once guarantee is used.JmsSourceBuilder
JmsSourceBuilder. sharedConsumer(boolean isSharedConsumer)
Specifies whether the MessageConsumer of the JMS topic is shared, that is whethercreateSharedConsumer()
orcreateSharedDurableConsumer()
was used to create it in theconsumerFn(FunctionEx)
.