io.smallrye.reactive.messaging.jms

Class JmsConnectorOutgoingConfiguration

java.lang.Object

io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

io.smallrye.reactive.messaging.jms.JmsConnectorOutgoingConfiguration

public class JmsConnectorOutgoingConfiguration
extends JmsConnectorCommonConfiguration

Extract the outgoing configuration for the smallrye-jms connector.

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

config

Constructor Summary

Constructors

Constructor and Description
JmsConnectorOutgoingConfiguration(org.eclipse.microprofile.config.Config config) Creates a new JmsConnectorOutgoingConfiguration.

Method Summary

Modifier and Type	Method and Description
Optional<String>	getCorrelationId() Gets the correlation-id value from the configuration.
Optional<Long>	getDeliveryDelay() Gets the delivery-delay value from the configuration.
Optional<String>	getDeliveryMode() Gets the delivery-mode value from the configuration.
Optional<Boolean>	getDisableMessageId() Gets the disable-message-id value from the configuration.
Optional<Boolean>	getDisableMessageTimestamp() Gets the disable-message-timestamp value from the configuration.
Boolean	getMerge() Gets the merge value from the configuration.
Optional<Integer>	getPriority() Gets the priority value from the configuration.
Optional<String>	getReplyTo() Gets the reply-to value from the configuration.
String	getReplyToDestinationType() Gets the reply-to-destination-type value from the configuration.
Optional<Long>	getTtl() Gets the ttl value from the configuration.
void	validate()

Methods inherited from class io.smallrye.reactive.messaging.jms.JmsConnectorCommonConfiguration

config, getChannel, getClientId, getConnectionFactoryName, getDestination, getDestinationType, getFromAlias, getFromAliasWithDefaultValue, getPassword, getSessionMode, getUsername

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JmsConnectorOutgoingConfiguration

public JmsConnectorOutgoingConfiguration(org.eclipse.microprofile.config.Config config)

Creates a new JmsConnectorOutgoingConfiguration.

Method Detail

getDisableMessageId

public Optional<Boolean> getDisableMessageId()

Gets the disable-message-id value from the configuration. Attribute Name: disable-message-id Description: Omit the message id in the outbound JMS message

Returns:

the disable-message-id

getDisableMessageTimestamp

public Optional<Boolean> getDisableMessageTimestamp()

Gets the disable-message-timestamp value from the configuration. Attribute Name: disable-message-timestamp Description: Omit the message timestamp in the outbound JMS message

Returns:

the disable-message-timestamp

getDeliveryMode

public Optional<String> getDeliveryMode()

Gets the delivery-mode value from the configuration. Attribute Name: delivery-mode Description: The delivery mode. Either `persistent` or `non_persistent`

Returns:

the delivery-mode

getDeliveryDelay

public Optional<Long> getDeliveryDelay()

Gets the delivery-delay value from the configuration. Attribute Name: delivery-delay Description: The delivery delay

Returns:

the delivery-delay

getTtl

public Optional<Long> getTtl()

Gets the ttl value from the configuration. Attribute Name: ttl Description: The JMS Message time-to-live

Returns:

the ttl

getCorrelationId

public Optional<String> getCorrelationId()

Gets the correlation-id value from the configuration. Attribute Name: correlation-id Description: The JMS Message correlation id

Returns:

the correlation-id

getPriority

public Optional<Integer> getPriority()

Gets the priority value from the configuration. Attribute Name: priority Description: The JMS Message priority

Returns:

the priority

getReplyTo

public Optional<String> getReplyTo()

Gets the reply-to value from the configuration. Attribute Name: reply-to Description: The reply to destination if any

Returns:

the reply-to

getReplyToDestinationType

public String getReplyToDestinationType()

Gets the reply-to-destination-type value from the configuration. Attribute Name: reply-to-destination-type Description: The type of destination for the response. It can be either `queue` or `topic` Default Value: queue

Returns:

the reply-to-destination-type

getMerge

public Boolean getMerge()

Gets the merge value from the configuration. Attribute Name: merge Description: Whether the connector should allow multiple upstreams Default Value: false

Returns:

the merge

validate

public void validate()

Overrides:

validate in class JmsConnectorCommonConfiguration