Настройка очередей приема и отправки jms в одном классе конфигурации

У меня есть приведенный ниже класс конфигурации mq, с помощью которого я могу получать сообщения в очереди приема, но при использовании bean-компонента JmsTemplate мои сообщения не отправляются в очередь. Я не получаю никаких 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) {...}

person M06H    schedule 07.11.2019    source источник


Ответы (1)


Вы не показываете свой слушатель, но почему у вас две очереди?

Похоже, вы отправляете в одну очередь, а получаете из другой. Вы должны получать из того же места, куда вы отправляете.

person Gary Russell    schedule 07.11.2019
comment
это две отдельные очереди, одна для приема и одна для отправки, но они находятся на одном канале/менеджере очередей. Итак, я думаю, что это неправильная конфигурация, и мне нужно создать другую фабрику соединений для получателя и отправителя? правильно ли я понимаю? - person M06H; 07.11.2019
comment
Это не имеет смысла; если вы отправляете по адресу foo и получаете от адресата bar, вы ничего не получите, и сообщения будут накапливаться в очереди foo. - person Gary Russell; 07.11.2019
comment
Я получаю от foo (локальный mq) и отправляю на bar (удаленная очередь). они оба находятся в диспетчере очередей X. Я получаю сообщение от foo в порядке, как и в текущей настройке, описанной выше. обновленный вопрос со слушателем. - person M06H; 07.11.2019