add mq sample

ipipman · Jul 14, 2024 · 8c01e57 · 8c01e57
1 parent 995bc2a
commit 8c01e57
Show file tree

Hide file tree

Showing 7 changed files with 5 additions and 30 deletions.
diff --git a/...ring-demo/src/main/java/cn/ipman/mq/client/spring/demo/MqClientSpringDemoApplication.java b/...ring-demo/src/main/java/cn/ipman/mq/client/spring/demo/MqClientSpringDemoApplication.java
@@ -23,12 +23,10 @@ public static void main(String[] args) {
         SpringApplication.run(MqClientSpringDemoApplication.class, args);
     }
 
-
     @Bean
     @SuppressWarnings("unchecked")
     public ApplicationRunner runner(@Autowired ApplicationContext context) {
         return x -> {
-
             int ids = 0;
             String topic = "im.order";
 

diff --git a/...n/ipman/mq/client/demo/ConsumerDemo1.java → ...ent/spring/demo/sample/ConsumerDemo1.java b/...n/ipman/mq/client/demo/ConsumerDemo1.java → ...ent/spring/demo/sample/ConsumerDemo1.java
@@ -1,4 +1,4 @@
-package cn.ipman.mq.client.demo;
+package cn.ipman.mq.client.spring.demo.sample;
 
 import cn.ipman.mq.client.broker.MQBroker;
 import cn.ipman.mq.client.broker.MQConsumer;

diff --git a/...n/ipman/mq/client/demo/ConsumerDemo2.java → ...ent/spring/demo/sample/ConsumerDemo2.java b/...n/ipman/mq/client/demo/ConsumerDemo2.java → ...ent/spring/demo/sample/ConsumerDemo2.java
@@ -1,4 +1,4 @@
-package cn.ipman.mq.client.demo;
+package cn.ipman.mq.client.spring.demo.sample;
 
 import cn.ipman.mq.client.broker.MQBroker;
 import cn.ipman.mq.client.broker.MQConsumer;

diff --git a/...n/ipman/mq/client/demo/ConsumerDemo3.java → ...ent/spring/demo/sample/ConsumerDemo3.java b/...n/ipman/mq/client/demo/ConsumerDemo3.java → ...ent/spring/demo/sample/ConsumerDemo3.java
@@ -1,4 +1,4 @@
-package cn.ipman.mq.client.demo;
+package cn.ipman.mq.client.spring.demo.sample;
 
 import cn.ipman.mq.client.broker.MQBroker;
 import cn.ipman.mq.client.broker.MQConsumer;

diff --git a/...n/mq/client/spring/demo/ListenerDemo.java → ...ient/spring/demo/sample/ListenerDemo.java b/...n/mq/client/spring/demo/ListenerDemo.java → ...ient/spring/demo/sample/ListenerDemo.java
@@ -1,4 +1,4 @@
-package cn.ipman.mq.client.spring.demo;
+package cn.ipman.mq.client.spring.demo.sample;
 
 import cn.ipman.mq.client.annotation.MQListener;
 import cn.ipman.mq.metadata.model.Message;

diff --git a/...ipman/mq/client/demo/NettyClientDemo.java → ...t/spring/demo/sample/NettyClientDemo.java b/...ipman/mq/client/demo/NettyClientDemo.java → ...t/spring/demo/sample/NettyClientDemo.java
@@ -1,4 +1,4 @@
-package cn.ipman.mq.client.demo;
+package cn.ipman.mq.client.spring.demo.sample;
 
 
 import cn.ipman.mq.client.client.netty.NettyMQClient;

diff --git a/mq-client/src/main/java/cn/ipman/mq/client/demo/SpringAnnotationListenerDemo.java b/mq-client/src/main/java/cn/ipman/mq/client/demo/SpringAnnotationListenerDemo.java