注释

src/main/java/org/redkale/mq/MessageConsumer.java

@@ -11,6 +11,29 @@ import org.redkale.util.AnyValue;
 /**
  * MQ消费器， 实现类必须标记{@link org.redkale.mq.ResourceConsumer}
  *
+ * <blockquote>
+ * <pre>
+ * &#64;ResourceConsumer(mq = "mymq", topics = "test_bean_topic")
+ * public class TestMessageConsumer implements MessageConsumer&lt;TestBean&gt; {
+ *
+ *     &#64;Override
+ *     public void init(AnyValue config) {
+ *         System.out.println("执行 TestMessageConsumer.init");
+ *     }
+ *
+ *     &#64;Override
+ *     public void onMessage(MessageConext context, TestBean message) {
+ *         System.out.println("TestMessageConsumer消费消息, context: " + context + ", message: " + message);
+ *     }
+ *
+ *     &#64;Override
+ *     public void destroy(AnyValue config) {
+ *         System.out.println("执行 TestMessageConsumer.destroy");
+ *     }
+ * }
+ * </pre>
+ * </blockquote>
+ *
  * <p>详情见: https://redkale.org
  *
  * @see org.redkale.mq.MessageConext

src/main/java/org/redkale/mq/MessageProducer.java

@@ -10,6 +10,27 @@ import org.redkale.convert.Convert;
 /**
  * MQ消息发送器 {@link org.redkale.mq.ResourceProducer}
  *
+ * <blockquote>
+ * <pre>
+ * public class TestMessageService extends AbstractService {
+ *
+ *     &#64;ResourceProducer(mq = "mymq")
+ *      private MessageProducer producer;
+ *
+ *      &#64;Override
+ *      public void init(AnyValue config) {
+ *           sendMessage();
+ *      }
+ *
+ *      public void sendMessage() {
+ *           TestBean bean = new TestBean(12345, "this is a message");
+ *           System.out.println("生产消息: " + bean);
+ *           producer.sendMessage("test_bean_topic", bean);
+ *      }
+ * }
+ * </pre>
+ * </blockquote>
+ *
  * <p>详情见: https://redkale.org
  *
  * @see org.redkale.mq.ResourceProducer

src/main/java/org/redkale/mq/Messaged.java

@@ -16,8 +16,8 @@ import org.redkale.service.LoadMode;
  * 1、方法必须是protected/public   <br>
  * 2、方法不能是final/static  <br>
  * 3、方法的参数只能是1个或者2个， 1个参数视为Message数据类型，2个参数则另一个必须是{@link org.redkale.mq.MessageConext} <br>
- * <blockquote>
  *
+ * <blockquote>
  * <pre>
  * public class MyMessageService extends AbstractService {
  *
@@ -37,7 +37,6 @@ import org.redkale.service.LoadMode;
  *    }
  * }
  * </pre>
- *
  * </blockquote>
  *
  * <p>详情见: https://redkale.org

src/main/java/org/redkale/mq/ResourceConsumer.java

@@ -12,6 +12,29 @@ import org.redkale.convert.ConvertType;
 /**
  * MQ资源注解, 只能标记在{@link org.redkale.mq.MessageConsumer}子类上
  *
+ * <blockquote>
+ * <pre>
+ * &#64;ResourceConsumer(mq = "mymq", topics = "test_bean_topic")
+ * public class TestMessageConsumer implements MessageConsumer&lt;TestBean&gt; {
+ *
+ *     &#64;Override
+ *     public void init(AnyValue config) {
+ *         System.out.println("执行 TestMessageConsumer.init");
+ *     }
+ *
+ *     &#64;Override
+ *     public void onMessage(MessageConext context, TestBean message) {
+ *         System.out.println("TestMessageConsumer消费消息, context: " + context + ", message: " + message);
+ *     }
+ *
+ *     &#64;Override
+ *     public void destroy(AnyValue config) {
+ *         System.out.println("执行 TestMessageConsumer.destroy");
+ *     }
+ * }
+ * </pre>
+ * </blockquote>
+ *
  * <p>详情见: https://redkale.org
  *
  * @see org.redkale.mq.MessageConsumer

src/main/java/org/redkale/mq/ResourceProducer.java

@@ -11,6 +11,27 @@ import org.redkale.convert.ConvertType;
 /**
  * MQ资源注解, 只能标记在{@link org.redkale.mq.MessageProducer}类型字段上
  *
+ * <blockquote>
+ * <pre>
+ * public class TestMessageService extends AbstractService {
+ *
+ *     &#64;ResourceProducer(mq = "mymq")
+ *      private MessageProducer producer;
+ *
+ *      &#64;Override
+ *      public void init(AnyValue config) {
+ *           sendMessage();
+ *      }
+ *
+ *      public void sendMessage() {
+ *           TestBean bean = new TestBean(12345, "this is a message");
+ *           System.out.println("生产消息: " + bean);
+ *           producer.sendMessage("test_bean_topic", bean);
+ *      }
+ * }
+ * </pre>
+ * </blockquote>
+ *
  * <p>详情见: https://redkale.org
  *
  * @see org.redkale.mq.MessageProducer

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

@@ -11,9 +11,9 @@ import org.redkale.convert.json.JsonConvert;
  * @author zhangjx
  */
 public class TestBean {
-    
+
     private int userid;
-    
+
     private String message;
 
     public TestBean() {}

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

@@ -32,7 +32,7 @@ public class TestMessageService extends AbstractService {
             if (t != null) {
                 t.printStackTrace();
             }
-            System.out.println("消息发送结果: " + v);
+            System.out.println("消息发送完成: " + v);
         });
     }