Uses of Class
org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

Packages that use RocketMQConsumerProperties

Package	Description
org.springframework.cloud.stream.binder.rocketmq
org.springframework.cloud.stream.binder.rocketmq.consuming
org.springframework.cloud.stream.binder.rocketmq.integration
org.springframework.cloud.stream.binder.rocketmq.properties
org.springframework.cloud.stream.binder.rocketmq.provisioning

Uses of RocketMQConsumerProperties in org.springframework.cloud.stream.binder.rocketmq

Methods in org.springframework.cloud.stream.binder.rocketmq that return RocketMQConsumerProperties

Modifier and Type	Method and Description
RocketMQConsumerProperties	RocketMQMessageChannelBinder.getExtendedConsumerProperties(String channelName)

Method parameters in org.springframework.cloud.stream.binder.rocketmq with type arguments of type RocketMQConsumerProperties

Modifier and Type	Method and Description
protected org.springframework.integration.core.MessageProducer	RocketMQMessageChannelBinder.createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties)

Uses of RocketMQConsumerProperties in org.springframework.cloud.stream.binder.rocketmq.consuming

Method parameters in org.springframework.cloud.stream.binder.rocketmq.consuming with type arguments of type RocketMQConsumerProperties

Modifier and Type	Method and Description
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer	ConsumersManager.getOrCreateConsumer(String group, String topic, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties)

Uses of RocketMQConsumerProperties in org.springframework.cloud.stream.binder.rocketmq.integration

Constructor parameters in org.springframework.cloud.stream.binder.rocketmq.integration with type arguments of type RocketMQConsumerProperties

Constructor and Description
RocketMQInboundChannelAdapter(ConsumersManager consumersManager, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties, String destination, String group, InstrumentationManager instrumentationManager)

Uses of RocketMQConsumerProperties in org.springframework.cloud.stream.binder.rocketmq.properties

Methods in org.springframework.cloud.stream.binder.rocketmq.properties that return RocketMQConsumerProperties

Modifier and Type	Method and Description
RocketMQConsumerProperties	RocketMQBindingProperties.getConsumer()
RocketMQConsumerProperties	RocketMQExtendedBindingProperties.getExtendedConsumerProperties(String channelName)

Methods in org.springframework.cloud.stream.binder.rocketmq.properties with parameters of type RocketMQConsumerProperties

Modifier and Type	Method and Description
void	RocketMQBindingProperties.setConsumer(RocketMQConsumerProperties consumer)

Uses of RocketMQConsumerProperties in org.springframework.cloud.stream.binder.rocketmq.provisioning

Method parameters in org.springframework.cloud.stream.binder.rocketmq.provisioning with type arguments of type RocketMQConsumerProperties

Modifier and Type	Method and Description
org.springframework.cloud.stream.provisioning.ConsumerDestination	RocketMQTopicProvisioner.provisionConsumerDestination(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> properties)