Я использую приложение IBM MQ + Spring Boot для прослушивания. Есть другой экземпляр MQ, где мы отправляем сообщение. Мы используем очередь передачи и канал отправителя/приемника для отправки/получения сообщения. Там нет проблем, когда у нас есть низкий объем сообщений. Когда мы увеличиваем объем сообщения, там начинается проблема. Приложение Java обычно получает сообщение через 10-15 секунд, даже если больше. Для обработки одного приложения Java обычно занимает 500/600 миллисекунд. Мы масштабируем приложение Java Helloader до 10 стручков (теперь у нас есть 10 слушателей). Тем не менее, у нас есть проблема. Любое решение/подход, чтобы найти проблему, будет оценен.define qlocal (TEST.XMIT) usage (xmitq) SCOPE(QMGR) MSGDLVSQ (FIFO) SHARE MAXDEPTH (9999) MAXMSGL(4194304) DEFPSIST(NO) DEFSOPT(EXCL) DEFREADA(NO) CUSTOM('CAPEXPRY(100)')
DEFINE CHANNEL(TEST) CHLTYPE(RCVR) TRPTYPE(TCP) HBINT(60) SSLCAUTH(REQUIRED) MAXMSGL(104857600) KAINT(99999) SEQWRAP(300) NPMSPEED(NORMAL) BATCHSZ(300) MRRTY(1) MRTMR(10) MONCHL(QMGR) STATCHL(QMGR)
< /code>
конфигурация прослушивателя Java. < /p>
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setAutoStartup(true);
container.setConnectionFactory(TESTConnectionFactory);
container.setDestinationName(DEST_QUE***);
container.setMessageListener(LISTENER_SERVICE);
container.setConcurrency("3-5");
Подробнее здесь: https://stackoverflow.com/questions/797 ... with-delay
