default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.autoFinish(Boolean autoFinish) |
Automatically finish the NSQ Message when it is retrieved from the
queue and before the Exchange is processed.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.autoFinish(String autoFinish) |
Automatically finish the NSQ Message when it is retrieved from the
queue and before the Exchange is processed.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.AdvancedNsqEndpointConsumerBuilder.basic() |
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.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 NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.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 NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.channel(String channel) |
The NSQ channel.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.customNSQLookup(Object customNSQLookup) |
A Custom NSQ lookup implementation.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.customNSQLookup(String customNSQLookup) |
A Custom NSQ lookup implementation.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.lookupInterval(long lookupInterval) |
The lookup interval.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.lookupInterval(String lookupInterval) |
The lookup interval.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.lookupServerPort(int lookupServerPort) |
The NSQ lookup server port.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.lookupServerPort(String lookupServerPort) |
The NSQ lookup server port.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.messageTimeout(long messageTimeout) |
The NSQ consumer timeout period for messages retrieved from the
queue.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.messageTimeout(String messageTimeout) |
The NSQ consumer timeout period for messages retrieved from the
queue.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.poolSize(int poolSize) |
Consumer pool size.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.poolSize(String poolSize) |
Consumer pool size.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.requeueInterval(long requeueInterval) |
The requeue interval in milliseconds.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.requeueInterval(String requeueInterval) |
The requeue interval in milliseconds.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.secure(boolean secure) |
Set secure option indicating TLS is required.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.secure(String secure) |
Set secure option indicating TLS is required.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.servers(String servers) |
The hostnames of one or more nsqlookupd servers (consumer) or nsqd
servers (producer).
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.sslContextParameters(Object sslContextParameters) |
To configure security using SSLContextParameters.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.sslContextParameters(String sslContextParameters) |
To configure security using SSLContextParameters.
|
default NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder |
NsqEndpointBuilderFactory.NsqEndpointConsumerBuilder.userAgent(String userAgent) |
A String to identify the kind of client.
|