Interface RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointProducerBuilder
,org.apache.camel.EndpointProducerResolver
- All Known Subinterfaces:
RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder
- Enclosing interface:
- RabbitMQEndpointBuilderFactory
public static interface RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder extends org.apache.camel.builder.EndpointProducerBuilder
Builder for endpoint producers for the RabbitMQ component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
additionalHeaders(String additionalHeaders)
Map of additional headers.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
additionalHeaders(Map<String,Object> additionalHeaders)
Map of additional headers.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
additionalProperties(String additionalProperties)
Map of additional properties.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
additionalProperties(Map<String,Object> additionalProperties)
Map of additional properties.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
addresses(String addresses)
If this option is set, camel-rabbitmq will try to create connection based on the setting of option addresses.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
advanced()
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
allowCustomHeaders(boolean allowCustomHeaders)
Allow pass custom values to header.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
allowCustomHeaders(String allowCustomHeaders)
Allow pass custom values to header.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
allowMessageBodySerialization(boolean allowMessageBodySerialization)
Whether to allow Java serialization of the message body or not.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
allowMessageBodySerialization(String allowMessageBodySerialization)
Whether to allow Java serialization of the message body or not.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
allowNullHeaders(boolean allowNullHeaders)
Allow pass null values to header.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
allowNullHeaders(String allowNullHeaders)
Allow pass null values to header.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
autoDelete(boolean autoDelete)
If it is true, the exchange will be deleted when it is no longer in use.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
autoDelete(String autoDelete)
If it is true, the exchange will be deleted when it is no longer in use.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
automaticRecoveryEnabled(Boolean automaticRecoveryEnabled)
Enables connection automatic recovery (uses connection implementation that performs automatic recovery when existing connection has failures).default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
automaticRecoveryEnabled(String automaticRecoveryEnabled)
Enables connection automatic recovery (uses connection implementation that performs automatic recovery when existing connection has failures).default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
bridgeEndpoint(boolean bridgeEndpoint)
If the bridgeEndpoint is true, the producer will ignore the message header of rabbitmq.EXCHANGE_NAME and rabbitmq.ROUTING_KEY.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
bridgeEndpoint(String bridgeEndpoint)
If the bridgeEndpoint is true, the producer will ignore the message header of rabbitmq.EXCHANGE_NAME and rabbitmq.ROUTING_KEY.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
channelPoolMaxSize(int channelPoolMaxSize)
Get maximum number of opened channel in pool.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
channelPoolMaxSize(String channelPoolMaxSize)
Get maximum number of opened channel in pool.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
channelPoolMaxWait(long channelPoolMaxWait)
Set the maximum number of milliseconds to wait for a channel from the pool.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
channelPoolMaxWait(String channelPoolMaxWait)
Set the maximum number of milliseconds to wait for a channel from the pool.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
connectionFactory(Object connectionFactory)
To use a custom RabbitMQ connection factory.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
connectionFactory(String connectionFactory)
To use a custom RabbitMQ connection factory.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
deadLetterExchange(String deadLetterExchange)
The name of the dead letter exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
deadLetterExchangeType(String deadLetterExchangeType)
The type of the dead letter exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
deadLetterQueue(String deadLetterQueue)
The name of the dead letter queue.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
deadLetterRoutingKey(String deadLetterRoutingKey)
The routing key for the dead letter exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
declare(boolean declare)
If the option is true, camel declare the exchange and queue name and bind them together.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
declare(String declare)
If the option is true, camel declare the exchange and queue name and bind them together.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
durable(boolean durable)
If we are declaring a durable exchange (the exchange will survive a server restart).default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
durable(String durable)
If we are declaring a durable exchange (the exchange will survive a server restart).default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
exchangeType(String exchangeType)
The exchange type such as direct or topic.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
exclusive(boolean exclusive)
Exclusive queues may only be accessed by the current connection, and are deleted when that connection closes.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
exclusive(String exclusive)
Exclusive queues may only be accessed by the current connection, and are deleted when that connection closes.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
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 RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
guaranteedDeliveries(String guaranteedDeliveries)
When true, an exception will be thrown when the message cannot be delivered (basic.return) and the message is marked as mandatory.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
hostname(String hostname)
The hostname of the running rabbitmq instance or cluster.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
immediate(boolean immediate)
This flag tells the server how to react if the message cannot be routed to a queue consumer immediately.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
immediate(String immediate)
This flag tells the server how to react if the message cannot be routed to a queue consumer immediately.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
lazyStartProducer(boolean lazyStartProducer)
Whether the producer should be started lazy (on the first message).default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
lazyStartProducer(String lazyStartProducer)
Whether the producer should be started lazy (on the first message).default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
mandatory(boolean mandatory)
This flag tells the server how to react if the message cannot be routed to a queue.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
mandatory(String mandatory)
This flag tells the server how to react if the message cannot be routed to a queue.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
passive(boolean passive)
Passive queues depend on the queue already to be available at RabbitMQ.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
passive(String passive)
Passive queues depend on the queue already to be available at RabbitMQ.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
password(String password)
Password for authenticated access.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
portNumber(int portNumber)
Port number for the host with the running rabbitmq instance or cluster.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
portNumber(String portNumber)
Port number for the host with the running rabbitmq instance or cluster.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
publisherAcknowledgements(boolean publisherAcknowledgements)
When true, the message will be published with publisher acknowledgements turned on.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
publisherAcknowledgements(String publisherAcknowledgements)
When true, the message will be published with publisher acknowledgements turned on.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
publisherAcknowledgementsTimeout(long publisherAcknowledgementsTimeout)
The amount of time in milliseconds to wait for a basic.ack response from RabbitMQ server.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
publisherAcknowledgementsTimeout(String publisherAcknowledgementsTimeout)
The amount of time in milliseconds to wait for a basic.ack response from RabbitMQ server.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
queue(String queue)
The queue to receive messages from.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
routingKey(String routingKey)
The routing key to use when binding a consumer queue to the exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipDlqDeclare(boolean skipDlqDeclare)
If true the producer will not declare and bind a dead letter queue.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipDlqDeclare(String skipDlqDeclare)
If true the producer will not declare and bind a dead letter queue.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipExchangeDeclare(boolean skipExchangeDeclare)
This can be used if we need to declare the queue but not the exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipExchangeDeclare(String skipExchangeDeclare)
This can be used if we need to declare the queue but not the exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipQueueBind(boolean skipQueueBind)
If true the queue will not be bound to the exchange after declaring it.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipQueueBind(String skipQueueBind)
If true the queue will not be bound to the exchange after declaring it.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipQueueDeclare(boolean skipQueueDeclare)
If true the producer will not declare and bind a queue.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
skipQueueDeclare(String skipQueueDeclare)
If true the producer will not declare and bind a queue.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
sslProtocol(String sslProtocol)
Enables SSL on connection, accepted value are true, TLS and 'SSLv3.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
trustManager(Object trustManager)
Configure SSL trust manager, SSL should be enabled for this option to be effective.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
trustManager(String trustManager)
Configure SSL trust manager, SSL should be enabled for this option to be effective.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
username(String username)
Username in case of authenticated access.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
vhost(String vhost)
The vhost for the channel.
-
-
-
Method Detail
-
advanced
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder advanced()
-
addresses
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder addresses(String addresses)
If this option is set, camel-rabbitmq will try to create connection based on the setting of option addresses. The addresses value is a string which looks like server1:12345, server2:12345. The option is a:java.lang.String
type. Group: common
-
autoDelete
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder autoDelete(boolean autoDelete)
If it is true, the exchange will be deleted when it is no longer in use. The option is a:boolean
type. Default: true Group: common
-
autoDelete
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder autoDelete(String autoDelete)
If it is true, the exchange will be deleted when it is no longer in use. The option will be converted to aboolean
type. Default: true Group: common
-
automaticRecoveryEnabled
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder automaticRecoveryEnabled(Boolean automaticRecoveryEnabled)
Enables connection automatic recovery (uses connection implementation that performs automatic recovery when existing connection has failures). The option is a:java.lang.Boolean
type. Default: true Group: common
-
automaticRecoveryEnabled
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder automaticRecoveryEnabled(String automaticRecoveryEnabled)
Enables connection automatic recovery (uses connection implementation that performs automatic recovery when existing connection has failures). The option will be converted to ajava.lang.Boolean
type. Default: true Group: common
-
connectionFactory
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder connectionFactory(Object connectionFactory)
To use a custom RabbitMQ connection factory. When this option is set, all connection options (connectionTimeout, requestedChannelMax...) set on URI are not used. The option is a:com.rabbitmq.client.ConnectionFactory
type. Group: common
-
connectionFactory
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder connectionFactory(String connectionFactory)
To use a custom RabbitMQ connection factory. When this option is set, all connection options (connectionTimeout, requestedChannelMax...) set on URI are not used. The option will be converted to acom.rabbitmq.client.ConnectionFactory
type. Group: common
-
deadLetterExchange
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder deadLetterExchange(String deadLetterExchange)
The name of the dead letter exchange. The option is a:java.lang.String
type. Group: common
-
deadLetterExchangeType
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder deadLetterExchangeType(String deadLetterExchangeType)
The type of the dead letter exchange. The option is a:java.lang.String
type. Default: direct Group: common
-
deadLetterQueue
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder deadLetterQueue(String deadLetterQueue)
The name of the dead letter queue. The option is a:java.lang.String
type. Group: common
-
deadLetterRoutingKey
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder deadLetterRoutingKey(String deadLetterRoutingKey)
The routing key for the dead letter exchange. The option is a:java.lang.String
type. Group: common
-
declare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder declare(boolean declare)
If the option is true, camel declare the exchange and queue name and bind them together. If the option is false, camel won't declare the exchange and queue name on the server. The option is a:boolean
type. Default: true Group: common
-
declare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder declare(String declare)
If the option is true, camel declare the exchange and queue name and bind them together. If the option is false, camel won't declare the exchange and queue name on the server. The option will be converted to aboolean
type. Default: true Group: common
-
durable
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder durable(boolean durable)
If we are declaring a durable exchange (the exchange will survive a server restart). The option is a:boolean
type. Default: true Group: common
-
durable
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder durable(String durable)
If we are declaring a durable exchange (the exchange will survive a server restart). The option will be converted to aboolean
type. Default: true Group: common
-
exchangeType
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder exchangeType(String exchangeType)
The exchange type such as direct or topic. The option is a:java.lang.String
type. Default: direct Group: common
-
exclusive
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder exclusive(boolean exclusive)
Exclusive queues may only be accessed by the current connection, and are deleted when that connection closes. The option is a:boolean
type. Default: false Group: common
-
exclusive
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder exclusive(String exclusive)
Exclusive queues may only be accessed by the current connection, and are deleted when that connection closes. The option will be converted to aboolean
type. Default: false Group: common
-
hostname
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder hostname(String hostname)
The hostname of the running rabbitmq instance or cluster. The option is a:java.lang.String
type. Group: common
-
passive
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder passive(boolean passive)
Passive queues depend on the queue already to be available at RabbitMQ. The option is a:boolean
type. Default: false Group: common
-
passive
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder passive(String passive)
Passive queues depend on the queue already to be available at RabbitMQ. The option will be converted to aboolean
type. Default: false Group: common
-
portNumber
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder portNumber(int portNumber)
Port number for the host with the running rabbitmq instance or cluster. Default value is 5672. The option is a:int
type. Group: common
-
portNumber
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder portNumber(String portNumber)
Port number for the host with the running rabbitmq instance or cluster. Default value is 5672. The option will be converted to aint
type. Group: common
-
queue
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder queue(String queue)
The queue to receive messages from. The option is a:java.lang.String
type. Group: common
-
routingKey
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder routingKey(String routingKey)
The routing key to use when binding a consumer queue to the exchange. For producer routing keys, you set the header rabbitmq.ROUTING_KEY. The option is a:java.lang.String
type. Group: common
-
skipDlqDeclare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipDlqDeclare(boolean skipDlqDeclare)
If true the producer will not declare and bind a dead letter queue. This can be used if you have also DLQ rabbitmq consumer and you want to avoid argument clashing between Producer and Consumer. This option have no effect, if DLQ configured (deadLetterExchange option is not set). The option is a:boolean
type. Default: false Group: common
-
skipDlqDeclare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipDlqDeclare(String skipDlqDeclare)
If true the producer will not declare and bind a dead letter queue. This can be used if you have also DLQ rabbitmq consumer and you want to avoid argument clashing between Producer and Consumer. This option have no effect, if DLQ configured (deadLetterExchange option is not set). The option will be converted to aboolean
type. Default: false Group: common
-
skipExchangeDeclare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipExchangeDeclare(boolean skipExchangeDeclare)
This can be used if we need to declare the queue but not the exchange. The option is a:boolean
type. Default: false Group: common
-
skipExchangeDeclare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipExchangeDeclare(String skipExchangeDeclare)
This can be used if we need to declare the queue but not the exchange. The option will be converted to aboolean
type. Default: false Group: common
-
skipQueueBind
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipQueueBind(boolean skipQueueBind)
If true the queue will not be bound to the exchange after declaring it. The option is a:boolean
type. Default: false Group: common
-
skipQueueBind
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipQueueBind(String skipQueueBind)
If true the queue will not be bound to the exchange after declaring it. The option will be converted to aboolean
type. Default: false Group: common
-
skipQueueDeclare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipQueueDeclare(boolean skipQueueDeclare)
If true the producer will not declare and bind a queue. This can be used for directing messages via an existing routing key. The option is a:boolean
type. Default: false Group: common
-
skipQueueDeclare
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipQueueDeclare(String skipQueueDeclare)
If true the producer will not declare and bind a queue. This can be used for directing messages via an existing routing key. The option will be converted to aboolean
type. Default: false Group: common
-
vhost
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder vhost(String vhost)
The vhost for the channel. The option is a:java.lang.String
type. Default: / Group: common
-
additionalHeaders
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder additionalHeaders(Map<String,Object> additionalHeaders)
Map of additional headers. These headers will be set only when the 'allowCustomHeaders' is set to true. The option is a:java.util.Map<java.lang.String, java.lang.Object>
type. Group: producer
-
additionalHeaders
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder additionalHeaders(String additionalHeaders)
Map of additional headers. These headers will be set only when the 'allowCustomHeaders' is set to true. The option will be converted to ajava.util.Map<java.lang.String, java.lang.Object>
type. Group: producer
-
additionalProperties
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder additionalProperties(Map<String,Object> additionalProperties)
Map of additional properties. These are standard RabbitMQ properties as defined in com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be ignored. The option is a:java.util.Map<java.lang.String, java.lang.Object>
type. Group: producer
-
additionalProperties
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder additionalProperties(String additionalProperties)
Map of additional properties. These are standard RabbitMQ properties as defined in com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be ignored. The option will be converted to ajava.util.Map<java.lang.String, java.lang.Object>
type. Group: producer
-
allowCustomHeaders
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowCustomHeaders(boolean allowCustomHeaders)
Allow pass custom values to header. The option is a:boolean
type. Default: false Group: producer
-
allowCustomHeaders
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowCustomHeaders(String allowCustomHeaders)
Allow pass custom values to header. The option will be converted to aboolean
type. Default: false Group: producer
-
allowNullHeaders
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowNullHeaders(boolean allowNullHeaders)
Allow pass null values to header. The option is a:boolean
type. Default: false Group: producer
-
allowNullHeaders
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowNullHeaders(String allowNullHeaders)
Allow pass null values to header. The option will be converted to aboolean
type. Default: false Group: producer
-
bridgeEndpoint
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder bridgeEndpoint(boolean bridgeEndpoint)
If the bridgeEndpoint is true, the producer will ignore the message header of rabbitmq.EXCHANGE_NAME and rabbitmq.ROUTING_KEY. The option is a:boolean
type. Default: false Group: producer
-
bridgeEndpoint
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder bridgeEndpoint(String bridgeEndpoint)
If the bridgeEndpoint is true, the producer will ignore the message header of rabbitmq.EXCHANGE_NAME and rabbitmq.ROUTING_KEY. The option will be converted to aboolean
type. Default: false Group: producer
-
channelPoolMaxSize
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder channelPoolMaxSize(int channelPoolMaxSize)
Get maximum number of opened channel in pool. The option is a:int
type. Default: 10 Group: producer
-
channelPoolMaxSize
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder channelPoolMaxSize(String channelPoolMaxSize)
Get maximum number of opened channel in pool. The option will be converted to aint
type. Default: 10 Group: producer
-
channelPoolMaxWait
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder channelPoolMaxWait(long channelPoolMaxWait)
Set the maximum number of milliseconds to wait for a channel from the pool. The option is a:long
type. Default: 1000 Group: producer
-
channelPoolMaxWait
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder channelPoolMaxWait(String channelPoolMaxWait)
Set the maximum number of milliseconds to wait for a channel from the pool. The option will be converted to along
type. Default: 1000 Group: producer
-
guaranteedDeliveries
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder 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. PublisherAcknowledgement will also be activated in this case. See also publisher acknowledgements - When will messages be confirmed. The option is a:boolean
type. Default: false Group: producer
-
guaranteedDeliveries
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder guaranteedDeliveries(String guaranteedDeliveries)
When true, an exception will be thrown when the message cannot be delivered (basic.return) and the message is marked as mandatory. PublisherAcknowledgement will also be activated in this case. See also publisher acknowledgements - When will messages be confirmed. The option will be converted to aboolean
type. Default: false Group: producer
-
immediate
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder immediate(boolean immediate)
This flag tells the server how to react if the message cannot be routed to a queue consumer immediately. If this flag is set, the server will return an undeliverable message with a Return method. If this flag is zero, the server will queue the message, but with no guarantee that it will ever be consumed. If the header is present rabbitmq.IMMEDIATE it will override this option. The option is a:boolean
type. Default: false Group: producer
-
immediate
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder immediate(String immediate)
This flag tells the server how to react if the message cannot be routed to a queue consumer immediately. If this flag is set, the server will return an undeliverable message with a Return method. If this flag is zero, the server will queue the message, but with no guarantee that it will ever be consumed. If the header is present rabbitmq.IMMEDIATE it will override this option. The option will be converted to aboolean
type. Default: false Group: producer
-
lazyStartProducer
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder lazyStartProducer(boolean lazyStartProducer)
Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option is a:boolean
type. Default: false Group: producer
-
lazyStartProducer
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder lazyStartProducer(String lazyStartProducer)
Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option will be converted to aboolean
type. Default: false Group: producer
-
mandatory
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder mandatory(boolean mandatory)
This flag tells the server how to react if the message cannot be routed to a queue. If this flag is set, the server will return an unroutable message with a Return method. If this flag is zero, the server silently drops the message. If the header is present rabbitmq.MANDATORY it will override this option. The option is a:boolean
type. Default: false Group: producer
-
mandatory
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder mandatory(String mandatory)
This flag tells the server how to react if the message cannot be routed to a queue. If this flag is set, the server will return an unroutable message with a Return method. If this flag is zero, the server silently drops the message. If the header is present rabbitmq.MANDATORY it will override this option. The option will be converted to aboolean
type. Default: false Group: producer
-
publisherAcknowledgements
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder publisherAcknowledgements(boolean publisherAcknowledgements)
When true, the message will be published with publisher acknowledgements turned on. The option is a:boolean
type. Default: false Group: producer
-
publisherAcknowledgements
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder publisherAcknowledgements(String publisherAcknowledgements)
When true, the message will be published with publisher acknowledgements turned on. The option will be converted to aboolean
type. Default: false Group: producer
-
publisherAcknowledgementsTimeout
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder publisherAcknowledgementsTimeout(long publisherAcknowledgementsTimeout)
The amount of time in milliseconds to wait for a basic.ack response from RabbitMQ server. The option is a:long
type. Group: producer
-
publisherAcknowledgementsTimeout
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder publisherAcknowledgementsTimeout(String publisherAcknowledgementsTimeout)
The amount of time in milliseconds to wait for a basic.ack response from RabbitMQ server. The option will be converted to along
type. Group: producer
-
allowMessageBodySerialization
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowMessageBodySerialization(boolean allowMessageBodySerialization)
Whether to allow Java serialization of the message body or not. If this value is true, the message body will be serialized on the producer side using Java serialization, if no type converter can handle the message body. On the consumer side, it will deserialize the message body if this value is true and the message contains a CamelSerialize header. Setting this value to true may introduce a security vulnerability as it allows an attacker to attempt to deserialize to a gadget object which could result in a RCE or other security vulnerability. The option is a:boolean
type. Default: false Group: allowMessageBodySerialization
-
allowMessageBodySerialization
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowMessageBodySerialization(String allowMessageBodySerialization)
Whether to allow Java serialization of the message body or not. If this value is true, the message body will be serialized on the producer side using Java serialization, if no type converter can handle the message body. On the consumer side, it will deserialize the message body if this value is true and the message contains a CamelSerialize header. Setting this value to true may introduce a security vulnerability as it allows an attacker to attempt to deserialize to a gadget object which could result in a RCE or other security vulnerability. The option will be converted to aboolean
type. Default: false Group: allowMessageBodySerialization
-
password
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder password(String password)
Password for authenticated access. The option is a:java.lang.String
type. Default: guest Group: security
-
sslProtocol
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder sslProtocol(String sslProtocol)
Enables SSL on connection, accepted value are true, TLS and 'SSLv3. The option is a:java.lang.String
type. Group: security
-
trustManager
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder trustManager(Object trustManager)
Configure SSL trust manager, SSL should be enabled for this option to be effective. The option is a:javax.net.ssl.TrustManager
type. Group: security
-
trustManager
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder trustManager(String trustManager)
Configure SSL trust manager, SSL should be enabled for this option to be effective. The option will be converted to ajavax.net.ssl.TrustManager
type. Group: security
-
username
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder username(String username)
Username in case of authenticated access. The option is a:java.lang.String
type. Default: guest Group: security
-
-