From 05a7e1a05d114ba9701fc91ad50e7694211dc724 Mon Sep 17 00:00:00 2001 From: fangjian0423 Date: Fri, 15 Mar 2019 17:39:52 +0800 Subject: [PATCH] update bus example 1.x --- .../rocketmq/RocketMQBusApplication.java | 7 ++++--- .../rocketmq/UserRemoteApplicationEvent.java | 16 ++++++++++------ 2 files changed, 14 insertions(+), 9 deletions(-) diff --git a/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/RocketMQBusApplication.java b/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/RocketMQBusApplication.java index 7e1b445e..0a163265 100644 --- a/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/RocketMQBusApplication.java +++ b/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/RocketMQBusApplication.java @@ -16,8 +16,6 @@ */ package org.springframework.cloud.alibaba.cloud.examples.rocketmq; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.ObjectMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; @@ -30,6 +28,9 @@ import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; + /** * RocketMQ Bus Spring Application * @@ -75,7 +76,7 @@ public class RocketMQBusApplication { user.setId(System.currentTimeMillis()); user.setName(name); publisher.publishEvent( - new UserRemoteApplicationEvent(user, originService, destination)); + new UserRemoteApplicationEvent(this, user, originService, destination)); return true; } diff --git a/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/UserRemoteApplicationEvent.java b/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/UserRemoteApplicationEvent.java index 8f2dd5ec..d5ec12f4 100644 --- a/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/UserRemoteApplicationEvent.java +++ b/spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/UserRemoteApplicationEvent.java @@ -16,8 +16,6 @@ */ package org.springframework.cloud.alibaba.cloud.examples.rocketmq; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonSubTypes; import org.springframework.cloud.bus.event.RemoteApplicationEvent; /** @@ -28,16 +26,22 @@ import org.springframework.cloud.bus.event.RemoteApplicationEvent; */ public class UserRemoteApplicationEvent extends RemoteApplicationEvent { + private User user; + public UserRemoteApplicationEvent() { } - public UserRemoteApplicationEvent(User user, String originService, + public UserRemoteApplicationEvent(Object source, User user, String originService, String destinationService) { - super(user, originService, destinationService); + super(source, originService, destinationService); + this.user = user; + } + + public void setUser(User user) { + this.user = user; } - @JsonIgnore public User getUser() { - return (User) getSource(); + return user; } }