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

Interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder

All Superinterfaces:

org.apache.camel.builder.EndpointConsumerBuilder, org.apache.camel.EndpointConsumerResolver

All Known Subinterfaces:

RocketMQEndpointBuilderFactory.RocketMQEndpointBuilder

Enclosing interface:

RocketMQEndpointBuilderFactory

public static interface RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder
extends org.apache.camel.builder.EndpointConsumerBuilder

Builder for endpoint consumers for the RocketMQ component.

Method Summary

Modifier and Type	Method	Description
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	accessChannel(String accessChannel)	Access channel of RocketMQ cluster.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	accessKey(String accessKey)	Access key for RocketMQ ACL.
default RocketMQEndpointBuilderFactory.AdvancedRocketMQEndpointConsumerBuilder	advanced()
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	consumerGroup(String consumerGroup)	Consumer group name.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	enableTrace(boolean enableTrace)	Whether to enable trace.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	enableTrace(String enableTrace)	Whether to enable trace.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	messageSelectorType(String messageSelectorType)	Message Selector Type, TAG or SQL TAG by default.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	namespace(String namespace)	Namespace of RocketMQ cluster.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	namesrvAddr(String namesrvAddr)	Name server address of RocketMQ cluster.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	secretKey(String secretKey)	Secret key for RocketMQ ACL.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	subscribeSql(String subscribeSql)	Subscribe SQL of consumer.
default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder	subscribeTags(String subscribeTags)	Subscribe tags of consumer.

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

doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUri

Methods inherited from interface org.apache.camel.EndpointConsumerResolver

resolve, resolve

Method Details

advanced

default RocketMQEndpointBuilderFactory.AdvancedRocketMQEndpointConsumerBuilder advanced()

accessChannel

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder 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

Parameters:

accessChannel - the value to set

Returns:

the dsl builder

enableTrace

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder enableTrace(boolean enableTrace)

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

Parameters:

enableTrace - the value to set

Returns:

the dsl builder

enableTrace

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder enableTrace(String enableTrace)

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

Parameters:

enableTrace - the value to set

Returns:

the dsl builder

namespace

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder 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

Parameters:

namespace - the value to set

Returns:

the dsl builder

namesrvAddr

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder namesrvAddr(String namesrvAddr)

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

Parameters:

namesrvAddr - the value to set

Returns:

the dsl builder

consumerGroup

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder consumerGroup(String consumerGroup)

Consumer group name. The option is a: java.lang.String type. Group: consumer

Parameters:

consumerGroup - the value to set

Returns:

the dsl builder

messageSelectorType

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder messageSelectorType(String messageSelectorType)

Message Selector Type, TAG or SQL TAG by default. The option is a: java.lang.String type. Default: tag Group: consumer

Parameters:

messageSelectorType - the value to set

Returns:

the dsl builder

subscribeSql

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder subscribeSql(String subscribeSql)

Subscribe SQL of consumer. See https://rocketmq.apache.org/docs/featureBehavior/07messagefilter/#attribute-based-sql-filtering for more details. The option is a: java.lang.String type. Default: 1 = 1 Group: consumer

Parameters:

subscribeSql - the value to set

Returns:

the dsl builder

subscribeTags

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder subscribeTags(String subscribeTags)

Subscribe tags of consumer. Multiple tags could be split by , such as TagATagB. The option is a: java.lang.String type. Default: * Group: consumer

Parameters:

subscribeTags - the value to set

Returns:

the dsl builder

accessKey

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder accessKey(String accessKey)

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

Parameters:

accessKey - the value to set

Returns:

the dsl builder

secretKey

default RocketMQEndpointBuilderFactory.RocketMQEndpointConsumerBuilder secretKey(String secretKey)

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

Parameters:

secretKey - the value to set

Returns:

the dsl builder