org.xmlBlaster.util.dispatch.plugins.prio
Class DispatchManagerEntry
java.lang.Object
org.xmlBlaster.util.dispatch.plugins.prio.DispatchManagerEntry
public final class DispatchManagerEntry
- extends java.lang.Object
Holds a dispatchManager and a plugin holdback queue.
The plugin is used for many DispatchManager instances. If
the plugin needs to hold back a message it is put into the holdback queue.
When the connection is fine again, the holdback queue is flushed to the
real queue of the DispatchManager.
- Author:
- xmlBlaster@marcelruff.info
- See Also:
- the dispatch.control.plugin requirement
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ME
private java.lang.String ME
dispatchManager
private final I_DispatchManager dispatchManager
holdbackQueue
private I_Queue holdbackQueue
currConnectionStateConfiguration
private StatusConfiguration currConnectionStateConfiguration
- This is the configuration for the current connection state of the dispatcher framework or null:
currConnectionState
private ConnectionStateEnum currConnectionState
DispatchManagerEntry
public DispatchManagerEntry(I_DispatchManager dispatchManager)
getDispatchManager
public I_DispatchManager getDispatchManager()
setCurrConnectionStateConfiguration
public void setCurrConnectionStateConfiguration(StatusConfiguration conf)
getCurrConnectionStateConfiguration
public StatusConfiguration getCurrConnectionStateConfiguration()
- This is the configuration for the current connection state of the dispatcher framework or null:
getCurrConnectionState
public ConnectionStateEnum getCurrConnectionState()
- The current state of the dispatcher connection
setCurrConnectionState
public void setCurrConnectionState(ConnectionStateEnum stateEnum)
getHoldbackQueue
public I_Queue getHoldbackQueue()
- Returns:
- null if no queue was allocated yet (lazy instantiation)
setHoldbackQueue
public void setHoldbackQueue(I_Queue holdbackQueue)
Copyright © 1999-2014 The xmlBlaster.org contributers.