- 
 @Documented @Target(FIELD) @Retention(RUNTIME) public @interface ResourceProducer MQ资源注解, 只能标记在MessageProducer类型字段上public class TestMessageService extends AbstractService { @ResourceProducer(mq = "mymq") private MessageProducer producer; @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); } }详情见: https://redkale.org - 从以下版本开始:
- 2.8.0
- 作者:
- zhangjx
- 另请参阅:
- MessageProducer
 
- 
- 
可选元素概要可选元素 修饰符和类型 可选元素 说明 ConvertTypeconvertType消息序列化类型StringmqMessageAgent对象对应名称booleanrequired是否必须要加载,为ture时若mq()值对应MessageAgent对象不存在的情况下会抛异常
 
- 
- 
- 
元素详细资料- 
mqString mq MessageAgent对象对应名称- 返回:
- MQ名称
 - 默认值:
- ""
 
 
- 
 - 
- 
requiredboolean required 是否必须要加载,为ture时若mq()值对应MessageAgent对象不存在的情况下会抛异常- 返回:
- 是否必须要加载
 - 默认值:
- true
 
 
- 
 - 
- 
convertTypeConvertType convertType 消息序列化类型- 返回:
- 序列化类型
 - 默认值:
- org.redkale.convert.ConvertType.JSON
 
 
- 
 
-