Interface RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointProducerBuilder
,org.apache.camel.EndpointProducerResolver
- All Known Subinterfaces:
RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
- Enclosing interface:
- RabbitMQEndpointBuilderFactory
public static interface RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder extends org.apache.camel.builder.EndpointProducerBuilder
Advanced builder for endpoint producers for the RabbitMQ component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
args(String key, Object value)
Specify arguments for configuring the different RabbitMQ concepts, a different prefix is required for each: Exchange: arg.exchange.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
args(Map values)
Specify arguments for configuring the different RabbitMQ concepts, a different prefix is required for each: Exchange: arg.exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
basic()
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
clientProperties(String clientProperties)
Connection client properties (client info used in negotiating with the server).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
clientProperties(Map<String,Object> clientProperties)
Connection client properties (client info used in negotiating with the server).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
connectionFactoryExceptionHandler(Object connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
connectionFactoryExceptionHandler(String connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
connectionTimeout(int connectionTimeout)
Connection timeout.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
connectionTimeout(String connectionTimeout)
Connection timeout.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
networkRecoveryInterval(Integer networkRecoveryInterval)
Network recovery interval in milliseconds (interval used when recovering from network failure).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
networkRecoveryInterval(String networkRecoveryInterval)
Network recovery interval in milliseconds (interval used when recovering from network failure).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestedChannelMax(int requestedChannelMax)
Connection requested channel max (max number of channels offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestedChannelMax(String requestedChannelMax)
Connection requested channel max (max number of channels offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestedFrameMax(int requestedFrameMax)
Connection requested frame max (max size of frame offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestedFrameMax(String requestedFrameMax)
Connection requested frame max (max size of frame offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestedHeartbeat(int requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestedHeartbeat(String requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestTimeout(long requestTimeout)
Set timeout for waiting for a reply when using the InOut Exchange Pattern (in milliseconds).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestTimeout(String requestTimeout)
Set timeout for waiting for a reply when using the InOut Exchange Pattern (in milliseconds).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestTimeoutCheckerInterval(long requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
requestTimeoutCheckerInterval(String requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
topologyRecoveryEnabled(Boolean topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
topologyRecoveryEnabled(String topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
transferException(boolean transferException)
When true and an inOut Exchange failed on the consumer side send the caused Exception back in the response.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
transferException(String transferException)
When true and an inOut Exchange failed on the consumer side send the caused Exception back in the response.
-
-
-
Method Detail
-
basic
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder basic()
-
args
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder args(String key, Object value)
Specify arguments for configuring the different RabbitMQ concepts, a different prefix is required for each: Exchange: arg.exchange. Queue: arg.queue. Binding: arg.binding. DLQ: arg.dlq.queue. DLQ binding: arg.dlq.binding. For example to declare a queue with message ttl argument: http://localhost:5672/exchange/queueargs=arg.queue.x-message-ttl=60000. The option is a:java.util.Map<java.lang.String, java.lang.Object>
type. The option is multivalued, and you can use the args(String, Object) method to add a value (call the method multiple times to set more values). Group: advanced
-
args
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder args(Map values)
Specify arguments for configuring the different RabbitMQ concepts, a different prefix is required for each: Exchange: arg.exchange. Queue: arg.queue. Binding: arg.binding. DLQ: arg.dlq.queue. DLQ binding: arg.dlq.binding. For example to declare a queue with message ttl argument: http://localhost:5672/exchange/queueargs=arg.queue.x-message-ttl=60000. The option is a:java.util.Map<java.lang.String, java.lang.Object>
type. The option is multivalued, and you can use the args(String, Object) method to add a value (call the method multiple times to set more values). Group: advanced
-
clientProperties
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder clientProperties(Map<String,Object> clientProperties)
Connection client properties (client info used in negotiating with the server). The option is a:java.util.Map<java.lang.String, java.lang.Object>
type. Group: advanced
-
clientProperties
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder clientProperties(String clientProperties)
Connection client properties (client info used in negotiating with the server). The option will be converted to ajava.util.Map<java.lang.String, java.lang.Object>
type. Group: advanced
-
connectionFactoryExceptionHandler
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder connectionFactoryExceptionHandler(Object connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory. The option is a:com.rabbitmq.client.ExceptionHandler
type. Group: advanced
-
connectionFactoryExceptionHandler
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder connectionFactoryExceptionHandler(String connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory. The option will be converted to acom.rabbitmq.client.ExceptionHandler
type. Group: advanced
-
connectionTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder connectionTimeout(int connectionTimeout)
Connection timeout. The option is a:int
type. Default: 60000 Group: advanced
-
connectionTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder connectionTimeout(String connectionTimeout)
Connection timeout. The option will be converted to aint
type. Default: 60000 Group: advanced
-
networkRecoveryInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder networkRecoveryInterval(Integer networkRecoveryInterval)
Network recovery interval in milliseconds (interval used when recovering from network failure). The option is a:java.lang.Integer
type. Default: 5000 Group: advanced
-
networkRecoveryInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder networkRecoveryInterval(String networkRecoveryInterval)
Network recovery interval in milliseconds (interval used when recovering from network failure). The option will be converted to ajava.lang.Integer
type. Default: 5000 Group: advanced
-
requestedChannelMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestedChannelMax(int requestedChannelMax)
Connection requested channel max (max number of channels offered). The option is a:int
type. Default: 2047 Group: advanced
-
requestedChannelMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestedChannelMax(String requestedChannelMax)
Connection requested channel max (max number of channels offered). The option will be converted to aint
type. Default: 2047 Group: advanced
-
requestedFrameMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestedFrameMax(int requestedFrameMax)
Connection requested frame max (max size of frame offered). The option is a:int
type. Default: 0 Group: advanced
-
requestedFrameMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestedFrameMax(String requestedFrameMax)
Connection requested frame max (max size of frame offered). The option will be converted to aint
type. Default: 0 Group: advanced
-
requestedHeartbeat
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestedHeartbeat(int requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered). The option is a:int
type. Default: 60 Group: advanced
-
requestedHeartbeat
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestedHeartbeat(String requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered). The option will be converted to aint
type. Default: 60 Group: advanced
-
requestTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestTimeout(long requestTimeout)
Set timeout for waiting for a reply when using the InOut Exchange Pattern (in milliseconds). The option is a:long
type. Default: 20000 Group: advanced
-
requestTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestTimeout(String requestTimeout)
Set timeout for waiting for a reply when using the InOut Exchange Pattern (in milliseconds). The option will be converted to along
type. Default: 20000 Group: advanced
-
requestTimeoutCheckerInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestTimeoutCheckerInterval(long requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange. The option is a:long
type. Default: 1000 Group: advanced
-
requestTimeoutCheckerInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder requestTimeoutCheckerInterval(String requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange. The option will be converted to along
type. Default: 1000 Group: advanced
-
synchronous
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). The option is a:boolean
type. Default: false Group: advanced
-
synchronous
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). The option will be converted to aboolean
type. Default: false Group: advanced
-
topologyRecoveryEnabled
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder topologyRecoveryEnabled(Boolean topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed). The option is a:java.lang.Boolean
type. Group: advanced
-
topologyRecoveryEnabled
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder topologyRecoveryEnabled(String topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed). The option will be converted to ajava.lang.Boolean
type. Group: advanced
-
transferException
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder transferException(boolean transferException)
When true and an inOut Exchange failed on the consumer side send the caused Exception back in the response. The option is a:boolean
type. Default: false Group: advanced
-
transferException
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder transferException(String transferException)
When true and an inOut Exchange failed on the consumer side send the caused Exception back in the response. The option will be converted to aboolean
type. Default: false Group: advanced
-
-