Interface RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder
,org.apache.camel.EndpointConsumerResolver
,org.apache.camel.builder.EndpointProducerBuilder
,org.apache.camel.EndpointProducerResolver
,RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
,RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
- Enclosing interface:
- RabbitMQEndpointBuilderFactory
public static interface RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder extends RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder, RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
Advanced builder for endpoint for the RabbitMQ component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
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.AdvancedRabbitMQEndpointBuilder
args(Map values)
Specify arguments for configuring the different RabbitMQ concepts, a different prefix is required for each: Exchange: arg.exchange.default RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder
basic()
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
clientProperties(String clientProperties)
Connection client properties (client info used in negotiating with the server).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
clientProperties(Map<String,Object> clientProperties)
Connection client properties (client info used in negotiating with the server).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
connectionFactoryExceptionHandler(Object connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
connectionFactoryExceptionHandler(String connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
connectionTimeout(int connectionTimeout)
Connection timeout.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
connectionTimeout(String connectionTimeout)
Connection timeout.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
networkRecoveryInterval(Integer networkRecoveryInterval)
Network recovery interval in milliseconds (interval used when recovering from network failure).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
networkRecoveryInterval(String networkRecoveryInterval)
Network recovery interval in milliseconds (interval used when recovering from network failure).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestedChannelMax(int requestedChannelMax)
Connection requested channel max (max number of channels offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestedChannelMax(String requestedChannelMax)
Connection requested channel max (max number of channels offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestedFrameMax(int requestedFrameMax)
Connection requested frame max (max size of frame offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestedFrameMax(String requestedFrameMax)
Connection requested frame max (max size of frame offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestedHeartbeat(int requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestedHeartbeat(String requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestTimeout(long requestTimeout)
Set timeout for waiting for a reply when using the InOut Exchange Pattern (in milliseconds).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestTimeout(String requestTimeout)
Set timeout for waiting for a reply when using the InOut Exchange Pattern (in milliseconds).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestTimeoutCheckerInterval(long requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
requestTimeoutCheckerInterval(String requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
topologyRecoveryEnabled(Boolean topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
topologyRecoveryEnabled(String topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed).default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
transferException(boolean transferException)
When true and an inOut Exchange failed on the consumer side send the caused Exception back in the response.default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder
transferException(String transferException)
When true and an inOut Exchange failed on the consumer side send the caused Exception back in the response.-
Methods inherited from interface org.apache.camel.builder.EndpointConsumerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, getUri
-
Methods inherited from interface org.apache.camel.builder.EndpointProducerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, expr, getUri
-
Methods inherited from interface org.apache.camel.builder.endpoint.dsl.RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
exceptionHandler, exceptionHandler, exchangePattern, exchangePattern, threadPoolSize, threadPoolSize
-
-
-
-
Method Detail
-
basic
default RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder basic()
- Specified by:
basic
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
basic
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
args
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
args
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
args
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
args
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
args
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
args
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
clientProperties
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
clientProperties
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
clientProperties
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
clientProperties
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
clientProperties
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
clientProperties
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
connectionFactoryExceptionHandler
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder connectionFactoryExceptionHandler(Object connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory. The option is a:com.rabbitmq.client.ExceptionHandler
type. Group: advanced- Specified by:
connectionFactoryExceptionHandler
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
connectionFactoryExceptionHandler
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
connectionFactoryExceptionHandler
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder connectionFactoryExceptionHandler(String connectionFactoryExceptionHandler)
Custom rabbitmq ExceptionHandler for ConnectionFactory. The option will be converted to acom.rabbitmq.client.ExceptionHandler
type. Group: advanced- Specified by:
connectionFactoryExceptionHandler
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
connectionFactoryExceptionHandler
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
connectionTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder connectionTimeout(int connectionTimeout)
Connection timeout. The option is a:int
type. Default: 60000 Group: advanced- Specified by:
connectionTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
connectionTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
connectionTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder connectionTimeout(String connectionTimeout)
Connection timeout. The option will be converted to aint
type. Default: 60000 Group: advanced- Specified by:
connectionTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
connectionTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
networkRecoveryInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
networkRecoveryInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
networkRecoveryInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
networkRecoveryInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
networkRecoveryInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
networkRecoveryInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestedChannelMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestedChannelMax(int requestedChannelMax)
Connection requested channel max (max number of channels offered). The option is a:int
type. Default: 2047 Group: advanced- Specified by:
requestedChannelMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestedChannelMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestedChannelMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestedChannelMax(String requestedChannelMax)
Connection requested channel max (max number of channels offered). The option will be converted to aint
type. Default: 2047 Group: advanced- Specified by:
requestedChannelMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestedChannelMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestedFrameMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestedFrameMax(int requestedFrameMax)
Connection requested frame max (max size of frame offered). The option is a:int
type. Default: 0 Group: advanced- Specified by:
requestedFrameMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestedFrameMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestedFrameMax
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestedFrameMax(String requestedFrameMax)
Connection requested frame max (max size of frame offered). The option will be converted to aint
type. Default: 0 Group: advanced- Specified by:
requestedFrameMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestedFrameMax
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestedHeartbeat
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestedHeartbeat(int requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered). The option is a:int
type. Default: 60 Group: advanced- Specified by:
requestedHeartbeat
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestedHeartbeat
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestedHeartbeat
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestedHeartbeat(String requestedHeartbeat)
Connection requested heartbeat (heart-beat in seconds offered). The option will be converted to aint
type. Default: 60 Group: advanced- Specified by:
requestedHeartbeat
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestedHeartbeat
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
requestTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestTimeout
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
requestTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestTimeout
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestTimeoutCheckerInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestTimeoutCheckerInterval(long requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange. The option is a:long
type. Default: 1000 Group: advanced- Specified by:
requestTimeoutCheckerInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestTimeoutCheckerInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
requestTimeoutCheckerInterval
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder requestTimeoutCheckerInterval(String requestTimeoutCheckerInterval)
Set requestTimeoutCheckerInterval for inOut exchange. The option will be converted to along
type. Default: 1000 Group: advanced- Specified by:
requestTimeoutCheckerInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
requestTimeoutCheckerInterval
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
synchronous
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
synchronous
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
synchronous
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
synchronous
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
synchronous
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
synchronous
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
topologyRecoveryEnabled
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder topologyRecoveryEnabled(Boolean topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed). The option is a:java.lang.Boolean
type. Group: advanced- Specified by:
topologyRecoveryEnabled
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
topologyRecoveryEnabled
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
topologyRecoveryEnabled
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder topologyRecoveryEnabled(String topologyRecoveryEnabled)
Enables connection topology recovery (should topology recovery be performed). The option will be converted to ajava.lang.Boolean
type. Group: advanced- Specified by:
topologyRecoveryEnabled
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
topologyRecoveryEnabled
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
transferException
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
transferException
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
transferException
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
transferException
default RabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointBuilder 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- Specified by:
transferException
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointConsumerBuilder
- Specified by:
transferException
in interfaceRabbitMQEndpointBuilderFactory.AdvancedRabbitMQEndpointProducerBuilder
-
-