Skip to content

io.helidon.messaging.connectors.aq.AqConfigBuilder

Description

Build AQ specific config

Configuration options

KeyTypeDefaultDescription
message-selectorStringJMS API message selector expression based on a subset of the SQL92
named-factoryStringSelect jakarta.jms.ConnectionFactory ConnectionFactory in case factory is injected as a named bean or configured with name
destinationStringQueue or topic name
subscriber-nameStringSubscriber name used to identify a durable subscription
transactedBooleanfalseIndicates whether the session will use a local transaction
non-localBooleanfalseWhen set to true, messages published by this connection, or any connection with the same client identifier, will not be delivered to this durable subscription
typeTypeQUEUESpecify if connection is io.helidon.messaging.connectors.jms.Type#QUEUE queue or io.helidon.messaging.connectors.jms.Type#TOPIC topic
durableBooleanfalseIndicates whether the consumer should be created as durable (only relevant for topic destinations)
passwordStringPassword used for creating JMS connection
poll-timeoutLong50Timeout for polling for next message in every poll cycle in millis
data-sourceStringMapping to javax.sql.DataSource DataSource supplied with io.helidon.messaging.connectors.aq.AqConnector.AqConnectorBuilder#dataSource(String, javax.sql.DataSource) AqConnectorBuilder.dataSource()
topicStringUse supplied destination name and Type#TOPIC TOPIC as type
acknowledge-modeAcknowledgeModeAUTO_ACKNOWLEDGEJMS acknowledgement mode
client-idStringClient identifier for JMS connection
period-executionsLong100Period for executing poll cycles in millis
queueStringUse supplied destination name and Type#QUEUE QUEUE as type
session-group-idStringWhen multiple channels share same session-group-id, they share same JMS session
usernameStringUser name used for creating JMS connection

See the manifest for all available types.