org.springframework.cloud.stream.binder.rocketmq.consuming

Class ConsumersManager

java.lang.Object

org.springframework.cloud.stream.binder.rocketmq.consuming.ConsumersManager

public class ConsumersManager
extends Object

Author:

Timur Valiev, Jim

Constructor Summary

Constructors

Constructor and Description
ConsumersManager(InstrumentationManager instrumentationManager, RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConsumersManager

public ConsumersManager(InstrumentationManager instrumentationManager,
                        RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties)

Method Detail

getOrCreateConsumer

public org.apache.rocketmq.client.consumer.DefaultMQPushConsumer getOrCreateConsumer(String group,
                                                                                     String topic,
                                                                                     org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties)

startConsumers

public void startConsumers()
                    throws org.apache.rocketmq.client.exception.MQClientException

Throws:

org.apache.rocketmq.client.exception.MQClientException

startConsumer

public void startConsumer(String group)
                   throws org.apache.rocketmq.client.exception.MQClientException

Throws:

org.apache.rocketmq.client.exception.MQClientException

stopConsumer

public void stopConsumer(String group)

getConsumerGroups

public Set<String> getConsumerGroups()