Class AmqpConnectorIncomingConfiguration
- java.lang.Object
-
- io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration
-
- io.smallrye.reactive.messaging.amqp.AmqpConnectorIncomingConfiguration
-
public class AmqpConnectorIncomingConfiguration extends AmqpConnectorCommonConfiguration
Extract the incoming configuration for thesmallrye-amqp
connector.
-
-
Field Summary
-
Fields inherited from class io.smallrye.reactive.messaging.amqp.AmqpConnectorCommonConfiguration
config
-
-
Constructor Summary
Constructors Constructor Description AmqpConnectorIncomingConfiguration(org.eclipse.microprofile.config.Config config)
Creates a new AmqpConnectorIncomingConfiguration.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Boolean
getAutoAcknowledgement()
Gets the auto-acknowledgement value from the configuration.Boolean
getBroadcast()
Gets the broadcast value from the configuration.Boolean
getDurable()
Gets the durable 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
-
getBroadcast
public Boolean getBroadcast()
Gets the broadcast value from the configuration. Attribute Name: broadcast Description: Whether the received AMQP messages must be dispatched to multiple _subscribers_ Default Value: false- Returns:
- the broadcast
-
getDurable
public Boolean getDurable()
Gets the durable value from the configuration. Attribute Name: durable Description: Whether AMQP subscription is durable Default Value: true- Returns:
- the durable
-
getAutoAcknowledgement
public Boolean getAutoAcknowledgement()
Gets the auto-acknowledgement value from the configuration. Attribute Name: auto-acknowledgement Description: Whether the received AMQP messages must be acknowledged when received Default Value: false- Returns:
- the auto-acknowledgement
-
validate
public void validate()
- Overrides:
validate
in classAmqpConnectorCommonConfiguration
-
-