io.smallrye.reactive.messaging.eventbus

Class VertxEventBusConnectorIncomingConfiguration

java.lang.Object

io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorIncomingConfiguration

public class VertxEventBusConnectorIncomingConfiguration
extends VertxEventBusConnectorCommonConfiguration

Extract the incoming configuration for the smallrye-vertx-eventbus connector.

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

config

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Boolean	getBroadcast() Gets the broadcast value from the configuration.
Boolean	getUseReplyAsAck() Gets the use-reply-as-ack value from the configuration.
void	validate()

Methods inherited from class io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

config, getAddress, getChannel, getFromAlias, getFromAliasWithDefaultValue

Methods inherited from class java.lang.Object

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

Constructor Detail

VertxEventBusConnectorIncomingConfiguration

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

Creates a new VertxEventBusConnectorIncomingConfiguration.

Method Detail

getBroadcast

public Boolean getBroadcast()

Gets the broadcast value from the configuration. Attribute Name: broadcast Description: Whether to dispatch the messages to multiple consumers Default Value: false

Returns:

the broadcast

getUseReplyAsAck

public Boolean getUseReplyAsAck()

Gets the use-reply-as-ack value from the configuration. Attribute Name: use-reply-as-ack Description: Whether acknowledgement is done by replying to the incoming message with a _dummy_ reply Default Value: false

Returns:

the use-reply-as-ack

validate

public void validate()

Overrides:

validate in class VertxEventBusConnectorCommonConfiguration