RocketMQ demo代码

spring-cloud-rocketmq/spring-cloud-rocketmq-consumer/src/main/java/com/gupaoedu/book/rocketmq/consumer/Application.java

@@ -9,13 +9,13 @@
 /**
  * @author juede.tcever
  */
-@EnableBinding({ Sink.class})
+@EnableBinding({ Sink.class, InputChannel.class})
 @SpringBootApplication
 public class Application {
 
-    @StreamListener(value = Sink.INPUT)
+    @StreamListener(value = InputChannel.ORDER_INPUT)
     public void receive(String receiveMsg) {
-        System.out.println("TopicTest2 receive: " + receiveMsg);
+        System.out.println("receive: " + receiveMsg);
     }
 
     public static void main(String[] args) {

spring-cloud-rocketmq/spring-cloud-rocketmq-consumer/src/main/java/com/gupaoedu/book/rocketmq/consumer/InputChannel.java

@@ -0,0 +1,20 @@
+package com.gupaoedu.book.rocketmq.consumer;
+
+import org.springframework.cloud.stream.annotation.Input;
+import org.springframework.messaging.SubscribableChannel;
+
+/**
+ * @author juede.tcever
+ */
+public interface InputChannel {
+
+    String USER_INPUT = "userInput";
+
+    String ORDER_INPUT = "orderInput";
+
+    @Input(InputChannel.USER_INPUT)
+    SubscribableChannel userInput();
+
+    @Input(InputChannel.ORDER_INPUT)
+    SubscribableChannel orderInput();
+}

spring-cloud-rocketmq/spring-cloud-rocketmq-consumer/src/main/java/com/gupaoedu/book/rocketmq/consumer/OrderSource.java

@@ -0,0 +1,15 @@
+package com.gupaoedu.book.rocketmq.consumer;
+
+import org.springframework.cloud.stream.annotation.Output;
+import org.springframework.messaging.MessageChannel;
+
+/**
+ * @author juede.tcever
+ */
+public interface OrderSource {
+
+    String OUTPUT = "orderOutput";
+
+    @Output(OrderSource.OUTPUT)
+    MessageChannel output();
+}