study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

update bus example 1.x

Browse Source
This commit is contained in:
fangjian0423 2019-03-15 17:39:52 +08:00
parent eb72043b9f
commit 05a7e1a05d
2 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/RocketMQBusApplication.java
View File

@ -16,8 +16,6 @@
*/ */
package org.springframework.cloud.alibaba.cloud.examples.rocketmq; 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.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration; 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.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
/** /**
* RocketMQ Bus Spring Application * RocketMQ Bus Spring Application
* *
@ -75,7 +76,7 @@ public class RocketMQBusApplication {
user.setId(System.currentTimeMillis()); user.setId(System.currentTimeMillis());
user.setName(name); user.setName(name);
publisher.publishEvent( publisher.publishEvent(
new UserRemoteApplicationEvent(user, originService, destination)); new UserRemoteApplicationEvent(this, user, originService, destination));
return true; return true;
} }

16
spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/UserRemoteApplicationEvent.java
View File

@ -16,8 +16,6 @@
*/ */
package org.springframework.cloud.alibaba.cloud.examples.rocketmq; 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; import org.springframework.cloud.bus.event.RemoteApplicationEvent;
/** /**
@ -28,16 +26,22 @@ import org.springframework.cloud.bus.event.RemoteApplicationEvent;
*/ */
public class UserRemoteApplicationEvent extends RemoteApplicationEvent { public class UserRemoteApplicationEvent extends RemoteApplicationEvent {
private User user;
public UserRemoteApplicationEvent() { public UserRemoteApplicationEvent() {
} }
public UserRemoteApplicationEvent(User user, String originService, public UserRemoteApplicationEvent(Object source, User user, String originService,
String destinationService) { 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() { public User getUser() {
return (User) getSource(); return user;
} }
} }