default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.allowNullBody(boolean allowNullBody) |
Whether to allow sending messages with no body.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.amqpAdmin(org.springframework.amqp.core.AmqpAdmin amqpAdmin) |
Optional AMQP Admin service to use for auto declaring elements
(queues, exchanges, bindings).
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.autoDeclare(boolean autoDeclare) |
Specifies whether the consumer should auto declare binding between
exchange, queue and routing key when starting.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.autoStartup(boolean autoStartup) |
Specifies whether the consumer container should auto-startup.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.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 SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.concurrentConsumers(int concurrentConsumers) |
The number of consumers.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.connectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
The connection factory to be use.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.deadLetterExchange(String deadLetterExchange) |
The name of the dead letter exchange.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.deadLetterExchangeType(String deadLetterExchangeType) |
The type of the dead letter exchange.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.deadLetterQueue(String deadLetterQueue) |
The name of the dead letter queue.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.deadLetterRoutingKey(String deadLetterRoutingKey) |
The routing key for the dead letter exchange.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.errorHandler(org.springframework.util.ErrorHandler errorHandler) |
To use a custom ErrorHandler for handling exceptions from the message
listener (consumer).
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter
header to and from Camel message.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.ignoreDeclarationExceptions(boolean ignoreDeclarationExceptions) |
Switch on ignore exceptions such as mismatched properties when
declaring.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.listenerContainerFactory(org.apache.camel.component.springrabbit.ListenerContainerFactory listenerContainerFactory) |
To use a custom factory for creating and configuring
ListenerContainer to be used by the consumer for receiving messages.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.maxConcurrentConsumers(Integer maxConcurrentConsumers) |
The maximum number of consumers (available only with SMLC).
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.maximumRetryAttempts(int maximumRetryAttempts) |
How many times a Rabbitmq consumer will retry the same message if
Camel failed to process the message.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) |
To use a custom MessageConverter so you can be in control how to map
to/from a org.springframework.amqp.core.Message.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.messageListenerContainerType(String messageListenerContainerType) |
The type of the MessageListenerContainer.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.messagePropertiesConverter(org.apache.camel.component.springrabbit.MessagePropertiesConverter messagePropertiesConverter) |
To use a custom MessagePropertiesConverter so you can be in control
how to map to/from a org.springframework.amqp.core.MessageProperties.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.prefetchCount(int prefetchCount) |
Tell the broker how many messages to send to each consumer in a
single request.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.rejectAndDontRequeue(boolean rejectAndDontRequeue) |
Whether a Rabbitmq consumer should reject the message without
requeuing.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.replyTimeout(long replyTimeout) |
Specify the timeout in milliseconds to be used when waiting for a
reply message when doing request/reply messaging.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.retry(org.springframework.retry.interceptor.RetryOperationsInterceptor retry) |
Custom retry configuration to use.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.retryDelay(int retryDelay) |
Delay in msec a Rabbitmq consumer will wait before redelivering a
message that Camel failed to process.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.shutdownTimeout(long shutdownTimeout) |
The time to wait for workers in milliseconds after the container is
stopped.
|
static SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.springRabbitmq() |
Spring RabbitMQ (camel-spring-rabbitmq)
Send and receive messages from RabbitMQ using Spring RabbitMQ client.
|
default SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder |
SpringRabbitmqComponentBuilderFactory.SpringRabbitmqComponentBuilder.testConnectionOnStartup(boolean testConnectionOnStartup) |
Specifies whether to test the connection on startup.
|