Package io.smallrye.reactive.messaging.amqp

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 the smallrye-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

Modifier and Type	Method	Description
Integer	getCreditRetrievalPeriod()	Gets the credit-retrieval-period value from the configuration.
Boolean	getDurable()	Gets the durable value from the configuration.
Boolean	getMerge()	Gets the merge 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, getLinkName, getPassword, getPort, getReconnectAttempts, getReconnectInterval, getSniServerName, getTracingEnabled, getUsername, getUseSsl, getVirtualHost

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpConnectorOutgoingConfiguration

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

Creates a new AmqpConnectorOutgoingConfiguration.

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: false

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

getCreditRetrievalPeriod

public Integer getCreditRetrievalPeriod()

Gets the credit-retrieval-period value from the configuration. Attribute Name: credit-retrieval-period Description: The period (in milliseconds) between two attempts to retrieve the credits granted by the broker. This time is used when the sender run out of credits. Default Value: 2000

Returns:

the credit-retrieval-period

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

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 AmqpConnectorCommonConfiguration