Class RabbitMQConnectorOutgoingConfiguration
- java.lang.Object
-
- io.smallrye.reactive.messaging.rabbitmq.RabbitMQConnectorCommonConfiguration
-
- io.smallrye.reactive.messaging.rabbitmq.RabbitMQConnectorOutgoingConfiguration
-
public class RabbitMQConnectorOutgoingConfiguration extends RabbitMQConnectorCommonConfiguration
Extract the outgoing configuration for thesmallrye-rabbitmq
connector.
-
-
Field Summary
-
Fields inherited from class io.smallrye.reactive.messaging.rabbitmq.RabbitMQConnectorCommonConfiguration
config
-
-
Constructor Summary
Constructors Constructor Description RabbitMQConnectorOutgoingConfiguration(org.eclipse.microprofile.config.Config config)
Creates a new RabbitMQConnectorOutgoingConfiguration.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getDefaultRoutingKey()
Gets the default-routing-key value from the configuration.Optional<Long>
getDefaultTtl()
Gets the default-ttl value from the configuration.Long
getMaxInflightMessages()
Gets the max-inflight-messages value from the configuration.Optional<Integer>
getMaxOutgoingInternalQueueSize()
Gets the max-outgoing-internal-queue-size value from the configuration.void
validate()
-
Methods inherited from class io.smallrye.reactive.messaging.rabbitmq.RabbitMQConnectorCommonConfiguration
config, getAutomaticRecoveryEnabled, getAutomaticRecoveryOnInitialConnection, getChannel, getConnectionTimeout, getExchangeAutoDelete, getExchangeDeclare, getExchangeDurable, getExchangeName, getExchangeType, getFromAlias, getFromAliasWithDefaultValue, getHandshakeTimeout, getHost, getIncludeProperties, getNetworkRecoveryInterval, getPassword, getPort, getReconnectAttempts, getReconnectInterval, getRequestedChannelMax, getRequestedHeartbeat, getTracingAttributeHeaders, getTracingEnabled, getUseNio, getUser, getUsername, getVirtualHost
-
-
-
-
Method Detail
-
getMaxOutgoingInternalQueueSize
public Optional<Integer> getMaxOutgoingInternalQueueSize()
Gets the max-outgoing-internal-queue-size value from the configuration. Attribute Name: max-outgoing-internal-queue-size Description: The maximum size of the outgoing internal queue- Returns:
- the max-outgoing-internal-queue-size
-
getMaxInflightMessages
public Long getMaxInflightMessages()
Gets the max-inflight-messages value from the configuration. Attribute Name: max-inflight-messages Description: The maximum number of messages to be written to RabbitMQ concurrently; must be a positive number Default Value: 1024- Returns:
- the max-inflight-messages
-
getDefaultRoutingKey
public String getDefaultRoutingKey()
Gets the default-routing-key value from the configuration. Attribute Name: default-routing-key Description: The default routing key to use when sending messages to the exchange Default Value:- Returns:
- the default-routing-key
-
getDefaultTtl
public Optional<Long> getDefaultTtl()
Gets the default-ttl value from the configuration. Attribute Name: default-ttl Description: If specified, the time (ms) sent messages can remain in queues undelivered before they are dead- Returns:
- the default-ttl
-
validate
public void validate()
- Overrides:
validate
in classRabbitMQConnectorCommonConfiguration
-
-