Блог

Я использую apache camel вместе с IBM MQ connection factory, соединенной вместе с помощью JMS. Когда я пытаюсь получать групповые сообщения, он всегда ждет сообщения с заголовком- «JMS_IBM_Last_Msg_In_Group», только тогда он обработает все сообщения одновременно. Я пытаюсь реализовать свой собственный секвенсор и агрегатор. Было бы здорово, если бы приложение не ждало начала обработки последнего сообщения.

Кто-нибудь может мне в этом помочь? 1.My фабрика соединений выглядит так.

 public MQQueueConnectionFactory mqQueueConnectionFactory(String hostname,String channel, String port,String queueManager) {
    // Create the connectionfactory which will be used to connect to IBM MQ
    MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
    mqQueueConnectionFactory.setHostName(hostname);
    try {
        mqQueueConnectionFactory.setTransportType(1);
        mqQueueConnectionFactory.setChannel(channel);
        mqQueueConnectionFactory.setPort(Integer.parseInt(port));
        mqQueueConnectionFactory.setQueueManager(queueManager);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return mqQueueConnectionFactory;
 

2.Фабрика подключения подключена к jms следующим образом

 JmsComponent jmsComponent1 = new JmsComponent();
    ConnectionFactory connectionFactory1=new ConnectionFactory();
    
    jmsComponent1.setConnectionFactory(connectionFactory1.mqQueueConnectionFactory( properties.getProperty("queue.hostname1"), properties.getProperty("queue.channel1"), properties.getProperty("queue.port1"), properties.getProperty("queue.queueManager1")));
    return jmsComponent1;