diff --git a/neutrino-core/src/test/java/fun/asgc/neutrino/core/base/event/Test3.java b/neutrino-core/src/test/java/fun/asgc/neutrino/core/base/event/Test3.java index a4ca0477..7b50e05b 100644 --- a/neutrino-core/src/test/java/fun/asgc/neutrino/core/base/event/Test3.java +++ b/neutrino-core/src/test/java/fun/asgc/neutrino/core/base/event/Test3.java @@ -22,6 +22,7 @@ package fun.asgc.neutrino.core.base.event; import com.alibaba.fastjson.JSONObject; +import com.google.common.collect.Sets; import fun.asgc.neutrino.core.util.SystemUtil; import lombok.Data; import lombok.experimental.Accessors; @@ -51,16 +52,18 @@ public class Test3 { } }; receiver1.setTopic("/*"); + receiver1.setTags(Sets.newHashSet("tag1")); ApplicationEventReceiver receiver2 = new ApplicationEventReceiver() { @Override public void receive(ApplicationEvent msg) { log.info("receiver2 data:{}", JSONObject.toJSONString(msg.data())); } }; + receiver2.setTags(Sets.newHashSet("tag2")); simpleApplicationEventManager.registerReceiver(receiver1); simpleApplicationEventManager.registerReceiver(receiver2); - simpleApplicationEventManager.publish("/aaa", null, new Student().setId("1").setName("张三").setAge(28).setSex("男")); + simpleApplicationEventManager.publish("/aaa", Sets.newHashSet("tag2"), new Student().setId("1").setName("张三").setAge(28).setSex("男")); SystemUtil.waitProcessDestroy().sync(); }