init db

themis-mq/src/main/java/com/qmth/themis/mq/listener/RocketMessageConsumer.java

@@ -34,16 +34,17 @@ public class RocketMessageConsumer {
      * @param consumerGroupName
      * @param topic
      * @param tag
+     * @param messageModel
      * @param o
      * @return
      */
-    public DefaultMQPushConsumer setRocketMQConsumer(String nameSrvAddr, String consumerGroupName, String topic, String tag, Object o) {
+    public DefaultMQPushConsumer setRocketMQConsumer(String nameSrvAddr, String consumerGroupName, String topic, String tag, MessageModel messageModel, Object o) {
         DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerGroupName);
         consumer.setNamesrvAddr(nameSrvAddr);
         consumer.setConsumeMessageBatchMaxSize(SystemConstant.CONSUME_MESSAGE_BATCH_MAX_SIZE);//每次拉取10条
         consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
         consumer.setMaxReconsumeTimes(SystemConstant.MAXRECONSUMETIMES);//最大重试次数
-        consumer.setMessageModel(MessageModel.BROADCASTING);
+        consumer.setMessageModel(messageModel);
         if (o instanceof MessageListenerConcurrently) {
             consumer.registerMessageListener((MessageListenerConcurrently) o);
         } else if (o instanceof MessageListenerOrderly) {