Package io.quarkus.smallrye.reactivemessaging.runtime

Interface ReactiveMessagingConfiguration

@ConfigRoot(phase=BUILD_AND_RUN_TIME_FIXED)
@ConfigMapping(prefix="quarkus.messaging")
public interface ReactiveMessagingConfiguration

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ReactiveMessagingConfiguration.ExecutionMode

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHANNEL_INCOMING_PROPERTY
static final String	CHANNEL_OUTGOING_PROPERTY

Method Summary

Modifier and Type	Method	Description
ReactiveMessagingConfiguration.ExecutionMode	blockingSignaturesExecutionMode()	Execution mode for the Messaging signatures considered "blocking", defaults to "worker".
static String	getChannelIncomingPropertyName(String channelName, String attribute)
static String	getChannelOutgoingPropertyName(String channelName, String attribute)
static String	getChannelPropertyName(String channelName, String attribute, boolean incoming)
boolean	metricsEnabled()	Whether Reactive Messaging metrics are published in case a metrics extension is present (default to false).
static String	normalizeChannelName(String name)	Normalize the name of a given channel.
boolean	strict()	Enables or disables the strict validation mode.

Field Details

CHANNEL_INCOMING_PROPERTY

static final String CHANNEL_INCOMING_PROPERTY

See Also:

• Constant Field Values

CHANNEL_OUTGOING_PROPERTY

static final String CHANNEL_OUTGOING_PROPERTY

See Also:

• Constant Field Values

Method Details

metricsEnabled

@WithName("metrics.enabled")
@WithDefault("false")
boolean metricsEnabled()

Whether Reactive Messaging metrics are published in case a metrics extension is present (default to false).

strict

@WithDefault("false")
boolean strict()

Enables or disables the strict validation mode.

blockingSignaturesExecutionMode

@WithName("blocking.signatures.execution.mode")
@WithDefault("worker")
ReactiveMessagingConfiguration.ExecutionMode blockingSignaturesExecutionMode()

Execution mode for the Messaging signatures considered "blocking", defaults to "worker". For the previous behaviour set to "event-loop".

normalizeChannelName

static String normalizeChannelName(String name)

Normalize the name of a given channel. Concatenate the channel name with double quotes when it contains dots.

Otherwise, the SmallRye Reactive Messaging only considers the text up to the first occurrence of a dot as the channel name.

Parameters:

name - the channel name.

Returns:

normalized channel name.

getChannelIncomingPropertyName

static String getChannelIncomingPropertyName(String channelName,
 String attribute)

getChannelOutgoingPropertyName

static String getChannelOutgoingPropertyName(String channelName,
 String attribute)

getChannelPropertyName

static String getChannelPropertyName(String channelName,
 String attribute,
 boolean incoming)