RetException优化

src/test/java/org/redkale/test/mq/TestMessageRegexConsumer.java

@@ -0,0 +1,36 @@
+/*
+
+ */
+
+package org.redkale.test.mq;
+
+import org.redkale.mq.MessageConsumer;
+import org.redkale.mq.MessageEvent;
+import org.redkale.mq.ResourceConsumer;
+import org.redkale.util.AnyValue;
+
+/**
+ *
+ * @author zhangjx
+ */
+@ResourceConsumer(mq = "mymq", regexTopic = "test_.*")
+public class TestMessageRegexConsumer implements MessageConsumer<TestBean> {
+
+    @Override
+    public void init(AnyValue config) {
+        System.out.println("执行 TestMessageRegexConsumer.init");
+    }
+
+    @Override
+    public void onMessage(MessageEvent<TestBean>[] events) {
+        for (MessageEvent<TestBean> event : events) {
+            System.out.println("TestMessageRegexConsumer消费消息, message: " + event.getMessage());
+        }
+    }
+
+    @Override
+    public void destroy(AnyValue config) {
+        System.out.println("执行 TestMessageRegexConsumer.destroy");
+    }
+}
+