default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.additionalHeaders(Map<String,Object> additionalHeaders) |
Map of additional headers.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.additionalProperties(Map<String,Object> additionalProperties) |
Map of additional properties.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.addresses(String addresses) |
If this option is set, camel-rabbitmq will try to create connection
based on the setting of option addresses.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.allowNullHeaders(boolean allowNullHeaders) |
Allow pass null values to header.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.args(Map<String,Object> args) |
Specify arguments for configuring the different RabbitMQ concepts, a
different prefix is required for each: Exchange: arg.exchange.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.autoAck(boolean autoAck) |
If messages should be auto acknowledged.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.autoDelete(boolean autoDelete) |
If it is true, the exchange will be deleted when it is no longer in
use.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.autoDetectConnectionFactory(boolean autoDetectConnectionFactory) |
Whether to auto-detect looking up RabbitMQ connection factory from
the registry.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.automaticRecoveryEnabled(Boolean automaticRecoveryEnabled) |
Enables connection automatic recovery (uses connection implementation
that performs automatic recovery when connection shutdown is not
initiated by the application).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.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 RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.channelPoolMaxSize(int channelPoolMaxSize) |
Get maximum number of opened channel in pool.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.channelPoolMaxWait(long channelPoolMaxWait) |
Set the maximum number of milliseconds to wait for a channel from the
pool.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.clientProperties(Map<String,Object> clientProperties) |
Connection client properties (client info used in negotiating with
the server).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.connectionFactory(com.rabbitmq.client.ConnectionFactory connectionFactory) |
To use a custom RabbitMQ connection factory.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.connectionFactoryExceptionHandler(com.rabbitmq.client.ExceptionHandler connectionFactoryExceptionHandler) |
Custom rabbitmq ExceptionHandler for ConnectionFactory.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.connectionTimeout(int connectionTimeout) |
Connection timeout.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.deadLetterExchange(String deadLetterExchange) |
The name of the dead letter exchange.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.deadLetterExchangeType(String deadLetterExchangeType) |
The type of the dead letter exchange.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.deadLetterQueue(String deadLetterQueue) |
The name of the dead letter queue.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.deadLetterRoutingKey(String deadLetterRoutingKey) |
The routing key for the dead letter exchange.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.declare(boolean declare) |
If the option is true, camel declare the exchange and queue name and
bind them together.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.durable(boolean durable) |
If we are declaring a durable exchange (the exchange will survive a
server restart).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.exclusive(boolean exclusive) |
Exclusive queues may only be accessed by the current connection, and
are deleted when that connection closes.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.exclusiveConsumer(boolean exclusiveConsumer) |
Request exclusive access to the queue (meaning only this consumer can
access the queue).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.guaranteedDeliveries(boolean guaranteedDeliveries) |
When true, an exception will be thrown when the message cannot be
delivered (basic.return) and the message is marked as mandatory.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.hostname(String hostname) |
The hostname of the running RabbitMQ instance or cluster.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.immediate(boolean immediate) |
This flag tells the server how to react if the message cannot be
routed to a queue consumer immediately.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.mandatory(boolean mandatory) |
This flag tells the server how to react if the message cannot be
routed to a queue.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.networkRecoveryInterval(Integer networkRecoveryInterval) |
Network recovery interval in milliseconds (interval used when
recovering from network failure).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.passive(boolean passive) |
Passive queues depend on the queue already to be available at
RabbitMQ.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.password(String password) |
Password for authenticated access.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.portNumber(int portNumber) |
Port number for the host with the running rabbitmq instance or
cluster.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.prefetchCount(int prefetchCount) |
The maximum number of messages that the server will deliver, 0 if
unlimited.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.prefetchEnabled(boolean prefetchEnabled) |
Enables the quality of service on the RabbitMQConsumer side.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.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 RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.prefetchSize(int prefetchSize) |
The maximum amount of content (measured in octets) that the server
will deliver, 0 if unlimited.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.publisherAcknowledgements(boolean publisherAcknowledgements) |
When true, the message will be published with publisher
acknowledgements turned on.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.publisherAcknowledgementsTimeout(long publisherAcknowledgementsTimeout) |
The amount of time in milliseconds to wait for a basic.ack response
from RabbitMQ server.
|
static RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.rabbitmq() |
RabbitMQ (camel-rabbitmq)
Send and receive messages from RabbitMQ instances.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.requestedChannelMax(int requestedChannelMax) |
Connection requested channel max (max number of channels offered).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.requestedFrameMax(int requestedFrameMax) |
Connection requested frame max (max size of frame offered).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.requestedHeartbeat(int requestedHeartbeat) |
Connection requested heartbeat (heart-beat in seconds offered).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.requestTimeout(long requestTimeout) |
Set timeout for waiting for a reply when using the InOut Exchange
Pattern (in milliseconds).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.requestTimeoutCheckerInterval(long requestTimeoutCheckerInterval) |
Set requestTimeoutCheckerInterval for inOut exchange.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.skipExchangeDeclare(boolean skipExchangeDeclare) |
This can be used if we need to declare the queue but not the
exchange.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.skipQueueBind(boolean skipQueueBind) |
If true the queue will not be bound to the exchange after declaring
it.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.skipQueueDeclare(boolean skipQueueDeclare) |
If true the producer will not declare and bind a queue.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.sslProtocol(String sslProtocol) |
Enables SSL on connection, accepted value are true, TLS and 'SSLv3.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.threadPoolSize(int threadPoolSize) |
The consumer uses a Thread Pool Executor with a fixed number of
threads.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.topologyRecoveryEnabled(Boolean topologyRecoveryEnabled) |
Enables connection topology recovery (should topology recovery be
performed).
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.transferException(boolean transferException) |
When true and an inOut Exchange failed on the consumer side send the
caused Exception back in the response.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.trustManager(TrustManager trustManager) |
Configure SSL trust manager, SSL should be enabled for this option to
be effective.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.username(String username) |
Username in case of authenticated access.
|
default RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder |
RabbitmqComponentBuilderFactory.RabbitmqComponentBuilder.vhost(String vhost) |
The vhost for the channel.
|