admin管理员组文章数量:1635681
正沉浸在撸代码的欢乐中,被大佬拍了下肩膀:“小伙儿,问你个问题啊.”,
搞的我顿时心头一颤,菊花一紧:“嗯...讲嘛”
“话说@JmsListener的destination属性怎么支持配置化呀?”
心弦一松,微笑一浮:“哦,这个呀,毛毛雨啦,简单,So Ea...”
一、yml中配置队列名称
自己适配.properties
ibmmq:
queue-test: TEST_QUEUE # 队列名称
二、注入配置读取类
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
/**
* 队列名称配置
* 这里切记要@Data,或手动set和get
*/
@Component
@Data
public class QueueNameConfig {
@Value("${ibmmq.queue-test}")
private String testQueue;
}
注意:必须要@Data,或手动set和get
三、@JmsListener消费者
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.listener.adapter.MessageListenerAdapter;
import org.springframework.stereotype.Component;
import javax.jms.Message;
import javax.jms.TextMessage;
/**
* IBM MQ消费者
*/
@Component
@Slf4j
public class ReceiveMessage extends MessageListenerAdapter {
/**
* destination:监听的队列名称,使用SpEL表达式写入
* containerFactory:监听的工厂类,为配置类中所配置的名字
*
* @param message
*/
@Override
@JmsListener(destination = "#{@queueNameConfig.testQueue}", containerFactory = "jmsListenerContainerFactory")
public void onMessage(Message message) {
TextMessage textMessage = (TextMessage) message; //转换成文本消息
try {
String text = textMessage.getText();
log.info("接收信息:{}", text);
} catch (Exception e) {
e.printStackTrace();
}
}
}
OK,就这么搞定!
本文标签: 注解属性SpringBootJmsListenerdestination
版权声明:本文标题:SpringBoot中@JmsListener注解属性destination支持配置化 内容由热心网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:https://www.elefans.com/dianzi/1729214409a1190251.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论