Я пытаюсь написать тест jUnit, чтобы показать, что JMS Функция подписчика start () запускает прослушиватель сообщений для темы (и этосообщения не использовались до вызова start () ).
Я столкнулся с проблемой, когда сообщения, помещенные в тему перед функцией start () Вызванные не обрабатываются после вызова start () .Сообщения, помещенные в тему после вызова start () , обрабатываются немедленно.
MockTopic topicWriter = getMockTopic(TOPIC);
// publish a message for the listener to pick up
MockObjectMessage objectMessage = new MockObjectMessage(message);
objectMessage.setBooleanProperty("Broadcast", true);
topicWriter.addMessage(objectMessage);
// the message doesn't get consumed because the subscriber has not been started
//...assert that the message is not processed... (**SUCCEEDS**)
// start the subscriber/listener
subscriber.start();
//...assert that the messages sitting on the topic get processed... (**FAILS**)
// publish a message for the listener to pick up
topicWriter.addMessage(objectMessage);
//...assert that the message gets processed... (**SUCCEEDS**)
Хотя это показывает, что слушатель не работает до start () ,отключение прослушивателя сообщений должно привести к обработке всех сообщений, находящихся в данный момент в теме.
Я попытался убедиться в том, что постоянство не было причиной, добавив:
objectMessage.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
, ноэто не помогло.
Фактически запущенная программа, кажется, указывает, что сообщения, в настоящее время находящиеся в Topic , обрабатываются в start () .Кто-нибудь знает, почему сообщения, в настоящее время MockTopic могут не обрабатываться в start () ?Это ограничение MockTopic ?