模块 org.redkale
程序包 org.redkale.mq

注释类型 ResourceConsumer

  • @ClassDepends
@Documented
@Target(TYPE)
@Retention(RUNTIME)
public @interface ResourceConsumer
    MQ资源注解, 只能标记在MessageConsumer子类上 
     @ResourceConsumer(mq = "mymq", topics = "test_bean_topic")
 public class TestMessageConsumer implements MessageConsumer<TestBean> {

     @Override
     public void init(AnyValue config) {
         System.out.println("执行 TestMessageConsumer.init");
     }

     @Override
     public void onMessage(MessageEvent<TestBean>[] events) {
        for(MessageEvent<TestBean> event : events) {
          System.out.println("TestMessageConsumer消费消息, message: " + event.getMessage());
        }
     }

     @Override
     public void destroy(AnyValue config) {
         System.out.println("执行 TestMessageConsumer.destroy");
     }
 }

    详情见: https://redkale.org

    从以下版本开始:
    2.8.0
    作者:
    zhangjx
    另请参阅:
    MessageConsumer

      • group

        String group
        MQ客户端分组名称
        返回:
        组名称
        默认值:
        ""

      • required

        boolean required
        是否必须要加载，为ture时若mq()值对应MessageAgent对象不存在的情况下会抛异常
        返回:
        是否必须要加载
        默认值:
        true

      • topics

        String[] topics
        监听的topic, 当regexTopic()值不为空时忽略此值
        返回:
        topic
        默认值:
        {}

      • regexTopic

        String regexTopic
        监听的topic， 与 topics()的值必须二选一，优先级高
        返回:
        topic正则表达式
        默认值:
        ""

      • convertType

        ConvertType convertType
        消息序列化类型
        返回:
        序列化类型
        默认值:
        org.redkale.convert.ConvertType.JSON