Uses of Class
com.hazelcast.jet.pipeline.JmsSourceBuilder
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of JmsSourceBuilder in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionJmsSourceBuilder.connectionFn
(FunctionEx<? super jakarta.jms.ConnectionFactory, ? extends jakarta.jms.Connection> connectionFn) Sets the function which creates the connection using the connection factory.JmsSourceBuilder.connectionParams
(String username, String password) Sets the connection parameters.JmsSourceBuilder.consumerFn
(FunctionEx<? super jakarta.jms.Session, ? extends jakarta.jms.MessageConsumer> consumerFn) Sets the function which creates the message consumer from session.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 JMSStreamSource
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 JMSStreamSource
for the Pipeline API.JmsSourceBuilder.maxGuarantee
(ProcessingGuarantee guarantee) Sets the maximum processing guarantee for the source.JmsSourceBuilder.messageIdFn
(FunctionEx<? super jakarta.jms.Message, ?> messageIdFn) Configures the function to extract IDs from the messages, if exactly-once guarantee is used.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)
.