From a71544a78d0b5320d0dd23a5d96c6cbed2dfc595 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Thu, 5 Oct 2023 21:22:06 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96group?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/mq/MessageAgent.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/redkale/mq/MessageAgent.java b/src/main/java/org/redkale/mq/MessageAgent.java
index 1e595a10b..72400b6f3 100644
--- a/src/main/java/org/redkale/mq/MessageAgent.java
+++ b/src/main/java/org/redkale/mq/MessageAgent.java
@@ -216,7 +216,9 @@ public abstract class MessageAgent implements Resourcable {
             for (MessageConsumer consumer : consumers) {
                 ResourceConsumer res = consumer.getClass().getAnnotation(ResourceConsumer.class);
                 String group = application.getPropertyValue(res.group());
-                group = consumer.getClass().getName() + (group.isEmpty() ? "" : ("-" + group));
+                if (Utility.isBlank(group)) {
+                    group = consumer.getClass().getName();
+                }
                 Map<String, MessageConsumerWrapper> map = maps.computeIfAbsent(group, g -> new HashMap<>());
                 for (String t : res.topics()) {
                     String topic = application.getPropertyValue(t);