正沉浸在撸代码的欢乐中,被大佬拍了下肩膀:“小伙儿,问你个问题啊.”,

搞的我顿时心头一颤,菊花一紧:“嗯...讲嘛”

“话说@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,就这么搞定!

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐