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

Packages that use 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 jakarta.jms.ConnectionFactory,? extends jakarta.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 jakarta.jms.Session,? extends jakarta.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 jakarta.jms.ConnectionFactory> factorySupplier)	Returns a builder object that offers a step-by-step fluent API to build a custom JMS StreamSource for the Pipeline API.
static JmsSourceBuilder	Sources.jmsTopicBuilder(SupplierEx<? extends jakarta.jms.ConnectionFactory> factorySupplier)	Returns a builder object that offers a step-by-step fluent API to build a custom JMS StreamSource for the Pipeline API.
JmsSourceBuilder	JmsSourceBuilder.maxGuarantee(ProcessingGuarantee guarantee)	Sets the maximum processing guarantee for the source.
JmsSourceBuilder	JmsSourceBuilder.messageIdFn(FunctionEx<? super jakarta.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 whether createSharedConsumer() or createSharedDurableConsumer() was used to create it in the consumerFn(FunctionEx).