default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.addresses(String addresses) |
If this option is set, camel-rabbitmq will try to create connection
based on the setting of option addresses.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.autoAck(boolean autoAck) |
If messages should be auto acknowledged.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.autoAck(String autoAck) |
If messages should be auto acknowledged.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.autoDelete(boolean autoDelete) |
If it is true, the exchange will be deleted when it is no longer in
use.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.autoDelete(String autoDelete) |
If it is true, the exchange will be deleted when it is no longer in
use.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.automaticRecoveryEnabled(Boolean automaticRecoveryEnabled) |
Enables connection automatic recovery (uses connection implementation
that performs automatic recovery when existing connection has
failures).
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.automaticRecoveryEnabled(String automaticRecoveryEnabled) |
Enables connection automatic recovery (uses connection implementation
that performs automatic recovery when existing connection has
failures).
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder.basic() |
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.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 RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.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 RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.concurrentConsumers(int concurrentConsumers) |
Number of concurrent consumers when consuming from broker.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.concurrentConsumers(String concurrentConsumers) |
Number of concurrent consumers when consuming from broker.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.connectionFactory(Object connectionFactory) |
To use a custom RabbitMQ connection factory.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.connectionFactory(String connectionFactory) |
To use a custom RabbitMQ connection factory.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.consumerTag(String consumerTag) |
Specify a client-generated consumer tag to establish context when
invoking the consume operation.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.deadLetterExchange(String deadLetterExchange) |
The name of the dead letter exchange.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.deadLetterExchangeType(String deadLetterExchangeType) |
The type of the dead letter exchange.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.deadLetterQueue(String deadLetterQueue) |
The name of the dead letter queue.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.deadLetterRoutingKey(String deadLetterRoutingKey) |
The routing key for the dead letter exchange.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.declare(boolean declare) |
If the option is true, camel declare the exchange and queue name and
bind them together.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.declare(String declare) |
If the option is true, camel declare the exchange and queue name and
bind them together.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.durable(boolean durable) |
If we are declaring a durable exchange (the exchange will survive a
server restart).
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.durable(String durable) |
If we are declaring a durable exchange (the exchange will survive a
server restart).
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.exchangeType(String exchangeType) |
The exchange type such as direct or topic.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.exclusive(boolean exclusive) |
Exclusive queues may only be accessed by the current connection, and
are deleted when that connection closes.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.exclusive(String exclusive) |
Exclusive queues may only be accessed by the current connection, and
are deleted when that connection closes.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.exclusiveConsumer(boolean exclusiveConsumer) |
Request exclusive access to the queue (meaning only this consumer can
access the queue).
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.exclusiveConsumer(String exclusiveConsumer) |
Request exclusive access to the queue (meaning only this consumer can
access the queue).
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.hostname(String hostname) |
The hostname of the running rabbitmq instance or cluster.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.passive(boolean passive) |
Passive queues depend on the queue already to be available at
RabbitMQ.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.passive(String passive) |
Passive queues depend on the queue already to be available at
RabbitMQ.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.password(String password) |
Password for authenticated access.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.portNumber(int portNumber) |
Port number for the host with the running rabbitmq instance or
cluster.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.portNumber(String portNumber) |
Port number for the host with the running rabbitmq instance or
cluster.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchCount(int prefetchCount) |
The maximum number of messages that the server will deliver, 0 if
unlimited.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchCount(String prefetchCount) |
The maximum number of messages that the server will deliver, 0 if
unlimited.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchEnabled(boolean prefetchEnabled) |
Enables the quality of service on the RabbitMQConsumer side.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchEnabled(String prefetchEnabled) |
Enables the quality of service on the RabbitMQConsumer side.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchGlobal(boolean prefetchGlobal) |
If the settings should be applied to the entire channel rather than
each consumer You need to specify the option of prefetchSize,
prefetchCount, prefetchGlobal at the same time.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchGlobal(String prefetchGlobal) |
If the settings should be applied to the entire channel rather than
each consumer You need to specify the option of prefetchSize,
prefetchCount, prefetchGlobal at the same time.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchSize(int prefetchSize) |
The maximum amount of content (measured in octets) that the server
will deliver, 0 if unlimited.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.prefetchSize(String prefetchSize) |
The maximum amount of content (measured in octets) that the server
will deliver, 0 if unlimited.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.queue(String queue) |
The queue to receive messages from.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.recoverFromDeclareException(boolean recoverFromDeclareException) |
Decides whether an exception during declaration of exchanges or
queues is recoverable or not.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.recoverFromDeclareException(String recoverFromDeclareException) |
Decides whether an exception during declaration of exchanges or
queues is recoverable or not.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.reQueue(boolean reQueue) |
This is used by the consumer to control rejection of the message.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.reQueue(String reQueue) |
This is used by the consumer to control rejection of the message.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.routingKey(String routingKey) |
The routing key to use when binding a consumer queue to the exchange.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipDlqDeclare(boolean skipDlqDeclare) |
If true the producer will not declare and bind a dead letter queue.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipDlqDeclare(String skipDlqDeclare) |
If true the producer will not declare and bind a dead letter queue.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipExchangeDeclare(boolean skipExchangeDeclare) |
This can be used if we need to declare the queue but not the
exchange.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipExchangeDeclare(String skipExchangeDeclare) |
This can be used if we need to declare the queue but not the
exchange.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipQueueBind(boolean skipQueueBind) |
If true the queue will not be bound to the exchange after declaring
it.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipQueueBind(String skipQueueBind) |
If true the queue will not be bound to the exchange after declaring
it.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipQueueDeclare(boolean skipQueueDeclare) |
If true the producer will not declare and bind a queue.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.skipQueueDeclare(String skipQueueDeclare) |
If true the producer will not declare and bind a queue.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.sslProtocol(String sslProtocol) |
Enables SSL on connection, accepted value are true, TLS and 'SSLv3.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.trustManager(Object trustManager) |
Configure SSL trust manager, SSL should be enabled for this option to
be effective.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.trustManager(String trustManager) |
Configure SSL trust manager, SSL should be enabled for this option to
be effective.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.username(String username) |
Username in case of authenticated access.
|
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder |
RabbitMQEndpointBuilderFactory.RabbitMQEndpointConsumerBuilder.vhost(String vhost) |
The vhost for the channel.
|