diff --git a/src/ReadMe.txt b/src/ReadMe.md similarity index 100% rename from src/ReadMe.txt rename to src/ReadMe.md diff --git a/src/pom.xml b/src/pom.xml index e082dab6d09693fd93b0b70ffb76a45d8be5b4f1..e4eda2ecfafbf462a787fafb595a2b7e7eabf1b3 100644 --- a/src/pom.xml +++ b/src/pom.xml @@ -40,6 +40,7 @@ project-sso project-quartz taoshop-common + project-search diff --git a/src/project-search/ReadMe.txt b/src/project-search/ReadMe.md similarity index 100% rename from src/project-search/ReadMe.txt rename to src/project-search/ReadMe.md diff --git a/src/project-sso/ReadMe.txt b/src/project-sso/ReadMe.md similarity index 100% rename from src/project-sso/ReadMe.txt rename to src/project-sso/ReadMe.md diff --git a/src/taoshop-common/ReadMe.txt b/src/taoshop-common/ReadMe.md similarity index 100% rename from src/taoshop-common/ReadMe.txt rename to src/taoshop-common/ReadMe.md diff --git a/src/taoshop-common/pom.xml b/src/taoshop-common/pom.xml index 04a4df4fb4023efb4a834cfa5914a97c9a421aad..7711353e324c27411fbe5a8dd552a559c1046054 100644 --- a/src/taoshop-common/pom.xml +++ b/src/taoshop-common/pom.xml @@ -13,4 +13,18 @@ jar + + + com.alibaba.rocketmq + rocketmq-client + 3.0.10 + + + com.alibaba.rocketmq + rocketmq-all + 3.0.10 + pom + + + \ No newline at end of file diff --git a/src/taoshop-common/src/test/java/com/mq/test/Consumer.java b/src/taoshop-common/src/test/java/com/mq/test/Consumer.java new file mode 100644 index 0000000000000000000000000000000000000000..b45d441f982dd7ee741cb2c715255b580cb7fe1b --- /dev/null +++ b/src/taoshop-common/src/test/java/com/mq/test/Consumer.java @@ -0,0 +1,34 @@ +package com.mq.test; + +import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer; +import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; +import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; +import com.alibaba.rocketmq.client.consumer.listener.MessageListenerConcurrently; +import com.alibaba.rocketmq.client.exception.MQClientException; +import com.alibaba.rocketmq.common.message.MessageExt; + +import java.util.List; + +public class Consumer { + public static void main(String[] args) throws MQClientException { + DefaultMQPushConsumer consumer = new DefaultMQPushConsumer( + "rmq-group"); + + consumer.setNamesrvAddr("123.207.63.192:9876"); + consumer.setInstanceName("consumer"); + consumer.subscribe("TopicA-test", "TagA"); + + consumer.registerMessageListener(new MessageListenerConcurrently() { + @Override + public ConsumeConcurrentlyStatus consumeMessage( + List msgs, ConsumeConcurrentlyContext context) { + for (MessageExt msg : msgs) { + System.out.println(new String(msg.getBody())); + } + return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; + } + }); + consumer.start(); + System.out.println("Consumer Started."); + } +} \ No newline at end of file diff --git a/src/taoshop-portal/ReadMe.txt b/src/taoshop-portal/ReadMe.md similarity index 100% rename from src/taoshop-portal/ReadMe.txt rename to src/taoshop-portal/ReadMe.md