禁止 : 做为 solon.cloud.event 的主题

lemonllm · Jun 18, 2024 · c7ea0cc · c7ea0cc
1 parent 8dcf3e8
commit c7ea0cc
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...ud/solon.cloud/src/main/java/org/noear/solon/cloud/impl/CloudEventServiceManagerImpl.java b/...ud/solon.cloud/src/main/java/org/noear/solon/cloud/impl/CloudEventServiceManagerImpl.java
@@ -88,6 +88,10 @@ public CloudEventServicePlus getOrThrow(String channel) {
      */
     @Override
     public boolean publish(Event event) throws CloudEventException {
+        if (event.topic().contains(":")) {
+            throw new IllegalArgumentException("Invalid symbol ':', topic=" + event.topic());
+        }
+
         CloudEventServicePlus tmp = getOrThrow(event.channel());
 
         if (Utils.isEmpty(event.group())) {
@@ -112,6 +116,10 @@ public boolean publish(Event event) throws CloudEventException {
      */
     @Override
     public void attention(EventLevel level, String channel, String group, String topic, String tag, int qos, CloudEventHandler observer) {
+        if (topic.contains(":")) {
+            throw new IllegalArgumentException("Invalid symbol ':', topic=" + topic);
+        }
+
         CloudEventServicePlus tmp = getOrThrow(channel);
 
         if (Utils.isEmpty(group)) {
@@ -120,4 +128,4 @@ public void attention(EventLevel level, String channel, String group, String top
 
         tmp.attention(level, channel, group, topic, tag, qos, observer);
     }
-}
+}