Interface PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder
,org.apache.camel.EndpointConsumerResolver
,org.apache.camel.builder.EndpointProducerBuilder
,org.apache.camel.EndpointProducerResolver
,PahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
,PahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
- Enclosing interface:
- PahoEndpointBuilderFactory
public static interface PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder extends PahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder, PahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
Advanced builder for endpoint for the Paho component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default PahoEndpointBuilderFactory.PahoEndpointBuilder
basic()
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
client(Object client)
To use an existing mqtt client.default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
client(String client)
To use an existing mqtt client.default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
customWebSocketHeaders(String customWebSocketHeaders)
Sets the Custom WebSocket Headers for the WebSocket Connection.default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
customWebSocketHeaders(Properties customWebSocketHeaders)
Sets the Custom WebSocket Headers for the WebSocket Connection.default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
executorServiceTimeout(int executorServiceTimeout)
Set the time in seconds that the executor service should wait when terminating before forcefully terminating.default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
executorServiceTimeout(String executorServiceTimeout)
Set the time in seconds that the executor service should wait when terminating before forcefully terminating.default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder
synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).-
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.PahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
exceptionHandler, exceptionHandler, exchangePattern, exchangePattern
-
-
-
-
Method Detail
-
basic
default PahoEndpointBuilderFactory.PahoEndpointBuilder basic()
- Specified by:
basic
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
basic
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
client
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder client(Object client)
To use an existing mqtt client. The option is a:org.eclipse.paho.client.mqttv3.MqttClient
type. Group: advanced- Specified by:
client
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
client
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
client
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder client(String client)
To use an existing mqtt client. The option will be converted to aorg.eclipse.paho.client.mqttv3.MqttClient
type. Group: advanced- Specified by:
client
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
client
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
customWebSocketHeaders
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder customWebSocketHeaders(Properties customWebSocketHeaders)
Sets the Custom WebSocket Headers for the WebSocket Connection. The option is a:java.util.Properties
type. Group: advanced- Specified by:
customWebSocketHeaders
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
customWebSocketHeaders
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
customWebSocketHeaders
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder customWebSocketHeaders(String customWebSocketHeaders)
Sets the Custom WebSocket Headers for the WebSocket Connection. The option will be converted to ajava.util.Properties
type. Group: advanced- Specified by:
customWebSocketHeaders
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
customWebSocketHeaders
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
executorServiceTimeout
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder executorServiceTimeout(int executorServiceTimeout)
Set the time in seconds that the executor service should wait when terminating before forcefully terminating. It is not recommended to change this value unless you are absolutely sure that you need to. The option is a:int
type. Default: 1 Group: advanced- Specified by:
executorServiceTimeout
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
executorServiceTimeout
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
executorServiceTimeout
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder executorServiceTimeout(String executorServiceTimeout)
Set the time in seconds that the executor service should wait when terminating before forcefully terminating. It is not recommended to change this value unless you are absolutely sure that you need to. The option will be converted to aint
type. Default: 1 Group: advanced- Specified by:
executorServiceTimeout
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
executorServiceTimeout
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
synchronous
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder 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 interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
synchronous
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
synchronous
default PahoEndpointBuilderFactory.AdvancedPahoEndpointBuilder 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 interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointConsumerBuilder
- Specified by:
synchronous
in interfacePahoEndpointBuilderFactory.AdvancedPahoEndpointProducerBuilder
-
-