From 933b9db6fb21d884d95b371265de5979f57387eb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?F=E5=98=89=E9=98=B3?= Date: Thu, 11 Oct 2018 09:03:11 +0800 Subject: [PATCH] =?UTF-8?q?=E7=B1=BB=E4=B9=8B=E9=97=B4=E8=A7=A3=E8=80=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/top/fjy8018/consumer/common/MySink.java | 2 +- .../src/main/java/top/fjy8018/consumer/common/MySource.java | 2 +- .../src/main/java/top/fjy8018/consumer/Consumer.java | 2 +- consumer/consumer-server/src/main/resources/application.yml | 2 +- .../src/main/java/top/fjy8018/producer/Producer.java | 5 ++--- producer/producer-server/src/main/resources/application.yml | 2 +- 6 files changed, 7 insertions(+), 8 deletions(-) diff --git a/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySink.java b/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySink.java index 571919c..8c5bf4e 100644 --- a/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySink.java +++ b/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySink.java @@ -11,6 +11,6 @@ import org.springframework.messaging.SubscribableChannel; public interface MySink { String INPUT = "input"; - @Input(Sink.INPUT) + @Input(MySink.INPUT) SubscribableChannel input(); } diff --git a/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySource.java b/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySource.java index cd36041..f321913 100644 --- a/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySource.java +++ b/consumer/consumer-common/src/main/java/top/fjy8018/consumer/common/MySource.java @@ -10,6 +10,6 @@ import org.springframework.messaging.MessageChannel; public interface MySource { String OUTPUT = "output"; - @Output("output") + @Output(MySource.OUTPUT) MessageChannel output(); } \ No newline at end of file diff --git a/consumer/consumer-server/src/main/java/top/fjy8018/consumer/Consumer.java b/consumer/consumer-server/src/main/java/top/fjy8018/consumer/Consumer.java index 0a378b7..94a6ac1 100644 --- a/consumer/consumer-server/src/main/java/top/fjy8018/consumer/Consumer.java +++ b/consumer/consumer-server/src/main/java/top/fjy8018/consumer/Consumer.java @@ -13,6 +13,6 @@ import top.fjy8018.consumer.common.MySink; public class Consumer { @StreamListener(MySink.INPUT) public void receive(Message message) { - System.out.println("接收到MQ消息:" + message); + System.out.println("接收到MQ消息:" + message.getPayload()); } } \ No newline at end of file diff --git a/consumer/consumer-server/src/main/resources/application.yml b/consumer/consumer-server/src/main/resources/application.yml index 0e0fd75..66d3e3a 100644 --- a/consumer/consumer-server/src/main/resources/application.yml +++ b/consumer/consumer-server/src/main/resources/application.yml @@ -1,6 +1,6 @@ spring: rabbitmq: - host: docker-1.fjy8018.cn + host: 192.168.163.128 username: cms password: cms-mq-admin cloud: diff --git a/producer/producer-server/src/main/java/top/fjy8018/producer/Producer.java b/producer/producer-server/src/main/java/top/fjy8018/producer/Producer.java index 838fbbd..95158c6 100644 --- a/producer/producer-server/src/main/java/top/fjy8018/producer/Producer.java +++ b/producer/producer-server/src/main/java/top/fjy8018/producer/Producer.java @@ -20,12 +20,11 @@ import java.util.Date; public class Producer { @Autowired - @Output(MySource.OUTPUT) - private MessageChannel channel; + private MySource channel; @RequestMapping("/send") public String send() { - channel.send(MessageBuilder.withPayload(new Date()).build()); + channel.output().send(MessageBuilder.withPayload(new Date()).build()); return "success"; } } diff --git a/producer/producer-server/src/main/resources/application.yml b/producer/producer-server/src/main/resources/application.yml index 1067ebf..63c78c1 100644 --- a/producer/producer-server/src/main/resources/application.yml +++ b/producer/producer-server/src/main/resources/application.yml @@ -1,6 +1,6 @@ spring: rabbitmq: - host: docker-1.fjy8018.cn + host: 192.168.163.128 username: cms password: cms-mq-admin cloud: