default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.AdvancedNatsEndpointConsumerBuilder.basic() |
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.connectionTimeout(int connectionTimeout) |
Timeout for connection attempts.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.connectionTimeout(String connectionTimeout) |
Timeout for connection attempts.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushConnection(boolean flushConnection) |
Define if we want to flush connection when stopping or not.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushConnection(String flushConnection) |
Define if we want to flush connection when stopping or not.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushTimeout(int flushTimeout) |
Set the flush timeout (in milliseconds).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushTimeout(String flushTimeout) |
Set the flush timeout (in milliseconds).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxMessages(String maxMessages) |
Stop receiving messages from a topic we are subscribing to after
maxMessages.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxPingsOut(int maxPingsOut) |
maximum number of pings have not received a response allowed by the
client.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxPingsOut(String maxPingsOut) |
maximum number of pings have not received a response allowed by the
client.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxReconnectAttempts(int maxReconnectAttempts) |
Max reconnection attempts.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxReconnectAttempts(String maxReconnectAttempts) |
Max reconnection attempts.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.noEcho(boolean noEcho) |
Turn off echo.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.noEcho(String noEcho) |
Turn off echo.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.noRandomizeServers(boolean noRandomizeServers) |
Whether or not randomizing the order of servers for the connection
attempts.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.noRandomizeServers(String noRandomizeServers) |
Whether or not randomizing the order of servers for the connection
attempts.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pedantic(boolean pedantic) |
Whether or not running in pedantic mode (this affects performance).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pedantic(String pedantic) |
Whether or not running in pedantic mode (this affects performance).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pingInterval(int pingInterval) |
Ping interval to be aware if connection is still alive (in
milliseconds).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pingInterval(String pingInterval) |
Ping interval to be aware if connection is still alive (in
milliseconds).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.poolSize(int poolSize) |
Consumer thread pool size (default is 10).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.poolSize(String poolSize) |
Consumer thread pool size (default is 10).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.queueName(String queueName) |
The Queue name if we are using nats for a queue configuration.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.reconnect(boolean reconnect) |
Whether or not using reconnection feature.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.reconnect(String reconnect) |
Whether or not using reconnection feature.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.reconnectTimeWait(int reconnectTimeWait) |
Waiting time before attempts reconnection (in milliseconds).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.reconnectTimeWait(String reconnectTimeWait) |
Waiting time before attempts reconnection (in milliseconds).
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.replyToDisabled(boolean replyToDisabled) |
Can be used to turn off sending back reply message in the consumer.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.replyToDisabled(String replyToDisabled) |
Can be used to turn off sending back reply message in the consumer.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.requestCleanupInterval(int requestCleanupInterval) |
Interval to clean up cancelled/timed out requests.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.requestCleanupInterval(String requestCleanupInterval) |
Interval to clean up cancelled/timed out requests.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.secure(boolean secure) |
Set secure option indicating TLS is required.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.secure(String secure) |
Set secure option indicating TLS is required.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.servers(String servers) |
URLs to one or more NAT servers.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.sslContextParameters(Object sslContextParameters) |
To configure security using SSLContextParameters.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.sslContextParameters(String sslContextParameters) |
To configure security using SSLContextParameters.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.verbose(boolean verbose) |
Whether or not running in verbose mode.
|
default NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder |
NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.verbose(String verbose) |
Whether or not running in verbose mode.
|