update

Author: kimmking

09mq/kmq-core/src/main/java/io/kimmking/kmq/core/KmqBroker.java

@@ -3,7 +3,7 @@
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
-public final class KmqBroker {
+public final class KmqBroker { // Broker+Connection
 
     public static final int CAPACITY = 10000;
 

09mq/kmq-core/src/main/java/io/kimmking/kmq/demo/KmqDemo.java

@@ -31,7 +31,7 @@ public static void main(String[] args) {
         }).start();
 
         KmqProducer producer = broker.createProducer();
-        for (int i = 0; i < 100; i++) {
+        for (int i = 0; i < 1000; i++) {
             Order order = new Order(1000L + i, System.currentTimeMillis(), "USD2CNY", 6.51d);
             producer.send(topic, new KmqMessage(null, order));
         }

09mq/pulsar/src/main/java/io/kimmking/mq/pulsar/ConsumerDemo.java

@@ -12,7 +12,7 @@ public class ConsumerDemo {
     public void consume() {
 
         Consumer consumer = Config.createClient().newConsumer()
-                .topic("my-topic")
+                .topic("my-kk")
                 .subscriptionName("my-subscription")
                 .subscribe();
 

09mq/pulsar/src/main/java/io/kimmking/mq/pulsar/ProducerDemo.java

@@ -12,7 +12,7 @@ public class ProducerDemo {
     @SneakyThrows
     public ProducerDemo(){
         stringProducer = Config.createClient().newProducer(Schema.STRING)
-                .topic("my-topic")
+                .topic("my-kk")
                 .create();
     }
 

09mq/rabbit/pom.xml

@@ -19,19 +19,19 @@
     </properties>
 
     <dependencies>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-activemq</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.boot</groupId>-->
+<!--            <artifactId>spring-boot-starter-activemq</artifactId>-->
+<!--        </dependency>-->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-amqp</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.apache.camel.springboot</groupId>
-            <artifactId>camel-spring-boot-starter</artifactId>
-            <version>3.7.0</version>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.apache.camel.springboot</groupId>-->
+<!--            <artifactId>camel-spring-boot-starter</artifactId>-->
+<!--            <version>3.7.0</version>-->
+<!--        </dependency>-->
 
 
 <!--        <dependency>-->

09mq/rabbit/src/main/java/io/kimmking/mq/rabbit/MsgProducer.java

@@ -26,7 +26,7 @@ public MsgProducer(RabbitTemplate rabbitTemplate) {
     public void sendMsg(String content) {
         CorrelationData correlationId = new CorrelationData(UUID.randomUUID().toString());
         //把消息放入ROUTINGKEY_A对应的队列当中去，对应的是队列A
-        rabbitTemplate.convertAndSend(RabbitConfig.EXCHANGE_A, RabbitConfig.ROUTINGKEY_A, content, correlationId);
+        rabbitTemplate.convertAndSend(RabbitConfig.EXCHANGE_A, RabbitConfig.ROUTINGKEY_B, content, correlationId);
     }
     /**
      * 回调

09mq/rabbit/src/main/java/io/kimmking/mq/rabbit/MsgReceiverA.java

@@ -8,7 +8,7 @@
 @Component
 @RabbitListener(queues = RabbitConfig.QUEUE_A)
 @Slf4j
-public class MsgReceiverA {
+public class MsgReceiverA { //guava ,  EventBus 的一些语法糖
 
     @RabbitHandler
     public void process(String content) {

09mq/rabbit/src/main/java/io/kimmking/mq/rabbit/RabbitConfig.java

@@ -90,7 +90,7 @@ public Queue queueC() {
 
     @Bean
     public Binding bindingA() {
-        return BindingBuilder.bind(queueA()).to(defaultExchange()).with(RabbitConfig.ROUTINGKEY_A);
+        return BindingBuilder.bind(queueA()).to(defaultExchange()).with(RabbitConfig.ROUTINGKEY_B);
     }
     @Bean
     public Binding bindingB() {