Package org.apache.camel.builder.endpoint.dsl

Interface RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder

All Superinterfaces:

org.apache.camel.builder.EndpointConsumerBuilder, org.apache.camel.EndpointConsumerResolver, org.apache.camel.builder.EndpointProducerBuilder, org.apache.camel.EndpointProducerResolver, RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder, RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Enclosing interface:

RocketMQEndpointBuilderFactory

public static interface RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder
extends RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder, RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Builder for endpoint for the RocketMQ component.

Method Summary

Modifier and Type	Method	Description
default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder	accessChannel(String accessChannel)	Access channel of RocketMQ cluster.
default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder	accessKey(String accessKey)	Access key for RocketMQ ACL.
default RocketMQEndpointBuilderFactory.AdvancedRocketMQEndpointBuilder	advanced()
default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder	enableTrace(boolean enableTrace)	Whether to enable trace.
default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder	enableTrace(String enableTrace)	Whether to enable trace.
default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder	namespace(String namespace)	Namespace of RocketMQ cluster.
default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder	namesrvAddr(String namesrvAddr)	Name server address of RocketMQ cluster.
default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder	secretKey(String secretKey)	Secret key for RocketMQ ACL.

Methods inherited from interface org.apache.camel.builder.EndpointConsumerBuilder

doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUri

Methods inherited from interface org.apache.camel.EndpointConsumerResolver

resolve, resolve

Methods inherited from interface org.apache.camel.builder.EndpointProducerBuilder

doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUri

Methods inherited from interface org.apache.camel.EndpointProducerResolver

resolve, resolve

Methods inherited from interface org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

consumerGroup, messageSelectorType, subscribeSql, subscribeTags

Methods inherited from interface org.apache.camel.builder.endpoint.dsl.RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

producerGroup, replyToConsumerGroup, replyToTopic, sendTag, waitForSendResult, waitForSendResult

Method Details

advanced

default RocketMQEndpointBuilderFactory.AdvancedRocketMQEndpointBuilder advanced()

Specified by:

advanced in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

advanced in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

accessChannel

default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder accessChannel(String accessChannel)

Access channel of RocketMQ cluster. LOCAL or CLOUD, LOCAL by default. The option is a: java.lang.String type. Default: LOCAL Group: common

Specified by:

accessChannel in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

accessChannel in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Parameters:

accessChannel - the value to set

Returns:

the dsl builder

enableTrace

default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder enableTrace(boolean enableTrace)

Whether to enable trace. The option is a: boolean type. Default: false Group: common

Specified by:

enableTrace in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

enableTrace in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Parameters:

enableTrace - the value to set

Returns:

the dsl builder

enableTrace

default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder enableTrace(String enableTrace)

Whether to enable trace. The option will be converted to a boolean type. Default: false Group: common

Specified by:

enableTrace in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

enableTrace in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Parameters:

enableTrace - the value to set

Returns:

the dsl builder

namespace

default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder namespace(String namespace)

Namespace of RocketMQ cluster. You need to specify this if you are using serverless version of RocketMQ. The option is a: java.lang.String type. Group: common

Specified by:

namespace in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

namespace in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Parameters:

namespace - the value to set

Returns:

the dsl builder

namesrvAddr

default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder namesrvAddr(String namesrvAddr)

Name server address of RocketMQ cluster. The option is a: java.lang.String type. Default: localhost:9876 Group: common

Specified by:

namesrvAddr in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

namesrvAddr in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Parameters:

namesrvAddr - the value to set

Returns:

the dsl builder

accessKey

default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder accessKey(String accessKey)

Access key for RocketMQ ACL. The option is a: java.lang.String type. Group: security

Specified by:

accessKey in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

accessKey in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Parameters:

accessKey - the value to set

Returns:

the dsl builder

secretKey

default RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder secretKey(String secretKey)

Secret key for RocketMQ ACL. The option is a: java.lang.String type. Group: security

Specified by:

secretKey in interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

Specified by:

secretKey in interface RocketMQEndpointBuilderFactory.RocketMQEndpointProducerBuilder

Parameters:

secretKey - the value to set

Returns:

the dsl builder