В моем проекте у меня есть все службы, разработанные как сеансовые компоненты без сохранения состояния. Во время рабочего процесса создаются новые данные, и об этом следует сообщать клиентам. Я хочу отправлять эти сообщения только тогда, когда транзакция успешно завершена.
У меня есть зарегистрированный ServletContextListener, который отправляет мои пакеты xmpp (библиотека smack). Когда я получаю пакет, я нахожу свой диспетчерский сеансовый компонент с отслеживанием состояния и начинаю обработку запроса.
public void processPacket(Packet packet) {
try{
if(packet instanceof RawRequest){
DispatchIQService service = Core.lookup(DispatchIQService.class);
service.process(connection, (RawRequest)packet);
// sending of the messages should happen here, because transaction completed successful.
}else{
log.debug("Packet ignored: " + packet.toXML());
}
}catch(Exception e){
log.error(e, e);
}
}
Как я могу собирать эти сгенерированные сообщения во время рабочего процесса через несколько компонентов? Я бы вернул этот список из компонента отправки и впоследствии отправил бы сообщения. Моим простым решением было бы маршрутизировать список, в который я добавляю свои сообщения, но есть ли более элегантный способ?
У меня есть ресурс XMPP (список http://www.igniterealtime.org/builds/smack/docs/latest/javadoc/org/jivesoftware/smack/Roster.html), к которому у меня есть доступ со всех компонентов. Как я могу это сделать? Хранить его в статической переменной и синхронизировать доступ к нему звучит не очень хорошо.
