Examples of handleNextMessages()

• org.xmlBlaster.util.dispatch.plugins.I_MsgDispatchInterceptor.handleNextMessages()
  messages from queue (none blocking) // we take all messages with same priority as a bulk ... ArrayList entryList = dispatchManager.getQueue().peekSamePriority(-1); // filter expired entries etc. ... // you should always call this method after taking messages from queue entryList = dispatchManager.prepareMsgsFromQueue(entryList); // ... do plugin specific work ... return entryList; @param pushEntries null: Take messages yourself from queue (async mode)
  not null: Use messages pushed (sync mode) or messages from ErrorCode.COMMUNICATION @return An ArrayList containing the I_QueueEntry to send.
  If list.size() == 0 the worker thread stops and does nothing
  If list.size() > 0 the given messages are sent. In case of pushEntries>0 and ErrorCode.COMMUNICATION* if you return them they are send to error handler. @exception If XmlBlasterException is thrown, dispatch of messages is stopped.Other exceptions will lead to giving up sending messages as configured with I_MsgErrorHandler, usually shutdown queue and sending dead messages.

Examples of org.xmlBlaster.util.dispatch.plugins.I_MsgDispatchInterceptor.handleNextMessages()