Package io.smallrye.reactive.messaging.eventbus

Class VertxEventBusConnectorOutgoingConfiguration

java.lang.Object

io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorCommonConfiguration

io.smallrye.reactive.messaging.eventbus.VertxEventBusConnectorOutgoingConfiguration

public class VertxEventBusConnectorOutgoingConfiguration
extends VertxEventBusConnectorCommonConfiguration

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

Field Summary

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

config

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Optional<String>	getCodec()	Gets the codec value from the configuration.
Boolean	getExpectReply()	Gets the expect-reply value from the configuration.
Boolean	getPublish()	Gets the publish value from the configuration.
Long	getTimeout()	Gets the timeout 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

VertxEventBusConnectorOutgoingConfiguration

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

Creates a new VertxEventBusConnectorOutgoingConfiguration.

Method Detail

getExpectReply

public Boolean getExpectReply()

Gets the expect-reply value from the configuration. Attribute Name: expect-reply Description: Whether the outgoing message is expecting a reply. This reply is used as acknowledgement Default Value: false

Returns:

the expect-reply

getPublish

public Boolean getPublish()

Gets the publish value from the configuration. Attribute Name: publish Description: Whether the to _publish_ the message to multiple Event Bus consumers. You cannot use `publish` in combination with `expect-reply`. Default Value: false

Returns:

the publish

getCodec

public Optional<String> getCodec()

Gets the codec value from the configuration. Attribute Name: codec Description: The name of the codec used to encode the outgoing message. The codec must have been registered.

Returns:

the codec

getTimeout

public Long getTimeout()

Gets the timeout value from the configuration. Attribute Name: timeout Description: The reply timeout (in ms), -1 to not set a timeout Default Value: -1

Returns:

the timeout

validate

public void validate()

Overrides:

validate in class VertxEventBusConnectorCommonConfiguration