RocketMQ Consumer

RocketMQ DefaultMQPushConsumer, config with Spring framework like this

<!-- RocketMQ DefaultMQPushConsumer-->
<bean id="rocketmqConsumer" class="org.apache.rocketmq.client.consumer.DefaultMQPushConsumer" init-method="start"
          destroy-method="shutdown">
        <property name="consumerGroup" value="conspringtest"/> <!-- Your consumer id -->
        <property name="namesrvAddr" value="localhost:9876"/> <!-- Your name server address -->
        <property name="messageListener" ref="messageListener"/> <!-- Your message listener -->
        <property name="subscription">
            <map>
                <entry key="QUEUE_TEST"> <!-- topic name -->
                    <value>*</value> <!-- subscribe tag -->
                </entry>
            </map>
        </property>
</bean>

Other config see Apache RocketMQ.