我有下面的mq config类,通过它我可以在接收队列中接收消息,但是当使用JmsTemplate bean时,我的消息没有发送到队列。
我没有收到任何JmsException
或任何异常,并且send()
似乎成功了。它是作为字符串发送的XML字符串,如下所示:
jmsTemplate.send(session -> session.createTextMessage(payload));
@EnableJms
@Configuration
public class MessageQueueConfiguration {
@Bean(name = "test-factory")
public ConnectionFactory getMqConnectionFactory(String host,int port,String queueManager,String channel) throws JMSException {
final MQConnectionFactory connectionFactory = new MQConnectionFactory();
connectionFactory.setQueueManager(queueManager);
connectionFactory.setHostName(host);
connectionFactory.setPort(port);
connectionFactory.setChannel(channel);
connectionFactory.setTransportType(WMQ_CM_CLIENT);
return connectionFactory;
}
@Bean("test-container")
public JmsListenerContainerFactory containerFactory(final ConnectionFactory connectionFactory,final ErrorHandler errorHandler) {
final DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setErrorHandler(errorHandler);
return factory;
}
@Bean(name = "receive")
public Destination receive(@Value("${receive-queue}") final String destination) throws JMSException {
return new Mqqueue(destination);
}
@Bean(name = "send")
public Destination send(@Value("${send-queue}") final String destination) throws JMSException {
return new Mqqueue(destination);
}
@Bean(name = "sender")
public JmsTemplate testTemplate(@Qualifier("test-factory") final ConnectionFactory connectionFactory,@Qualifier("send") final Destination destination) {
final JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);
jmsTemplate.setDefaultDestination(destination);
return jmsTemplate;
}
}
我的问题是我配置错误吗?接收和发送队列时,我需要多个连接工厂或容器工厂吗?
我的听众:
@JmsListener(destination = "${receive}",concurrency = "1-1",containerFactory = "test-container")
public Model<Message> getMessage(@Payload final String message) {...}