Class AmqpConnectorOutgoingConfiguration
- java.lang.Object
-
- io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration
-
- io.smallrye.reactive.messaging.amqp.AmqpConnectorOutgoingConfiguration
-
public class AmqpConnectorOutgoingConfiguration extends AmqpConnectorCommonConfiguration
Extract the outgoing configuration for thesmallrye-amqp
connector.
-
-
Field Summary
-
Fields inherited from class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration
config
-
-
Constructor Summary
Constructors Constructor Description AmqpConnectorOutgoingConfiguration(org.eclipse.microprofile.config.Config config)
Creates a new AmqpConnectorOutgoingConfiguration.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Boolean
getDurable()
Gets the durable value from the configuration.Long
getTtl()
Gets the ttl value from the configuration.Boolean
getUseAnonymousSender()
Gets the use-anonymous-sender value from the configuration.void
validate()
-
Methods inherited from class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration
config, getAddress, getChannel, getClientOptionsName, getConnectTimeout, getContainerId, getFromAlias, getFromAliasWithDefaultValue, getHost, getPassword, getPort, getReconnectAttempts, getReconnectInterval, getUsername, getUseSsl
-
-
-
-
Method Detail
-
getDurable
public Boolean getDurable()
Gets the durable value from the configuration. Attribute Name: durable Description: Whether sent AMQP messages are marked durable Default Value: true- Returns:
- the durable
-
getTtl
public Long getTtl()
Gets the ttl value from the configuration. Attribute Name: ttl Description: The time-to-live of the send AMQP messages. 0 to disable the TTL Default Value: 0- Returns:
- the ttl
-
getUseAnonymousSender
public Boolean getUseAnonymousSender()
Gets the use-anonymous-sender value from the configuration. Attribute Name: use-anonymous-sender Description: Whether or not the connector should use an anonymous sender. Default Value: true- Returns:
- the use-anonymous-sender
-
validate
public void validate()
- Overrides:
validate
in classAmqpConnectorCommonConfiguration
-
-