Listener

Consumer Listener config like this

<!-- Consumer Listener -->
<bean id="messageListener" class="org.darkphoenixs.mq.listener.MQMessageListenerAdapter">
        <property name="consumerAdapter" ref="consumerAdapter"/>
        <property name="messageDecoder" ref="messageDecoder"/>
        <property name="model" value="MODEL_1"/>
        <property name="batch" value="NON_BATCH"/>
        <property name="type" value="KAFKA"/> <!-- must be last set -->
</bean>

consumerAdapter : extends org.darkphoenixs.mq.consumer.MQConsumerAdapter. (Any type)

messageDecoder : implements org.darkphoenixs.mq.codec.MQMessageDecoder. (KAFKA or ROCKETMQ)

model : MODEL_1 is one consumer per thread, MODEL_2 is decouple consumption and processing. (KAFKA or ROCKETMQ)

batch : BATCH or NON_BATCH message processing. (KAFKA or ROCKETMQ)

type : KAFKA or ACTIVEMQ or ROCKETMQ.

Note: type must be last set !

Other configs see the Configuration wiki.