Producer

Producer config like this

<!-- Message Producer -->
<bean id="messageProducer" class="org.darkphoenixs.compatible.MQProducerDemo">
        <property name="topic" value="TOPIC_NAME"/>
        <property name="messageEncoder" ref="messageEncoder"/>
        <property name="activemqTemplate" ref="activemqTemplate"/>
        <property name="activemqDestination" ref="activemqDestination"/>
        <property name="rocketmqDefaultProducer" ref="rocketmqDefaultProducer"/>
        <property name="rocketmqTransactionProducer" ref="rocketmqTransactionProducer"/>
        <property name="kafkaMessageSenderPool" ref="kafkaMessageSenderPool"/>
        <!-- type must be last set -->
        <property name="type" value="KAFKA or ACTIVEMQ or ROCKETMQ"/>
</bean>

messageEncoder : implements org.darkphoenixs.mq.codec.MQMessageEncoder. (KAFKA or ROCKETMQ)

kafkaMessageSenderPool: implements org.darkphoenixs.kafka.pool.MessageSenderPool. (only KAFKA)

activemqTemplate : org.springframework.jms.core.JmsTemplate. (only ACTIVEMQ)

activemqDestination: destination name ActiveMQTopic or ActiveMQQueue. (only ACTIVEMQ)

rocketmqDefaultProducer : org.apache.rocketmq.client.producer.DefaultMQProducer. (only ROCKETMQ)

rocketmqTransactionProducer: org.apache.rocketmq.client.producer.TransactionMQProducer. (only ROCKETMQ)

topic : Topic name. (KAFKA or ROCKETMQ)

type : KAFKA or ACTIVEMQ or ROCKETMQ.

Note: type must be last set !

Other configs see the Configuration wiki.