|
xmlBlaster 2.0.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use DispatchManager | |
---|---|
org.xmlBlaster.authentication | |
org.xmlBlaster.client | This is the Java client side package. |
org.xmlBlaster.client.dispatch | |
org.xmlBlaster.contrib.mime | |
org.xmlBlaster.contrib.replication.impl | |
org.xmlBlaster.engine | The core implementation. |
org.xmlBlaster.engine.dispatch | |
org.xmlBlaster.engine.distributor.plugins | |
org.xmlBlaster.util | Java helper classes for server and client programming. |
org.xmlBlaster.util.dispatch | |
org.xmlBlaster.util.dispatch.plugins | |
org.xmlBlaster.util.dispatch.plugins.prio | |
org.xmlBlaster.util.error |
Uses of DispatchManager in org.xmlBlaster.authentication |
---|
Fields in org.xmlBlaster.authentication declared as DispatchManager | |
---|---|
private DispatchManager |
SessionInfo.dispatchManager
manager for sending callback messages |
Methods in org.xmlBlaster.authentication that return DispatchManager | |
---|---|
DispatchManager |
SessionInfo.getDispatchManager()
|
Uses of DispatchManager in org.xmlBlaster.client |
---|
Fields in org.xmlBlaster.client declared as DispatchManager | |
---|---|
private DispatchManager |
XmlBlasterAccess.dispatchManager
The dispatcher framework |
Methods in org.xmlBlaster.client with parameters of type DispatchManager | |
---|---|
void |
XmlBlasterAccess.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
Call by DispatchManager on connection state transition. |
void |
XmlBlasterAccess.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
XmlBlasterAccess.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
Call by DispatchManager on connection state transition. |
void |
XmlBlasterAccess.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
Call by DispatchManager on connection state transition. |
Uses of DispatchManager in org.xmlBlaster.client.dispatch |
---|
Constructors in org.xmlBlaster.client.dispatch with parameters of type DispatchManager | |
---|---|
ClientDispatchConnectionsHandler(Global glob,
DispatchManager dispatchManager)
|
Uses of DispatchManager in org.xmlBlaster.contrib.mime |
---|
Methods in org.xmlBlaster.contrib.mime with parameters of type DispatchManager | |
---|---|
void |
DropIfNotDeliverableUniqueOnly.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
DropIfNotDeliverable.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
DropIfNotDeliverableUniqueOnly.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
DropIfNotDeliverable.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
DropIfNotDeliverableUniqueOnly.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
|
void |
DropIfNotDeliverable.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
|
void |
DropIfNotDeliverableUniqueOnly.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
DropIfNotDeliverable.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
Uses of DispatchManager in org.xmlBlaster.contrib.replication.impl |
---|
Methods in org.xmlBlaster.contrib.replication.impl with parameters of type DispatchManager | |
---|---|
void |
ReplManagerPlugin.addDispatchManager(DispatchManager dispatchManager)
This method is invoked always so see sessionAdded javadoc. |
boolean |
ReplManagerPlugin.doActivate(DispatchManager dispatchManager)
|
java.util.List<I_Entry> |
ReplManagerPlugin.handleNextMessages(DispatchManager dispatchManager,
java.util.List<I_Entry> pushEntries)
|
void |
ReplManagerPlugin.onDispatchWorkerException(DispatchManager dispatchManager,
java.lang.Throwable ex)
|
void |
ReplManagerPlugin.postHandleNextMessages(DispatchManager dispatchManager,
MsgUnit[] processedEntries)
Does cleanup, particularly it sets the status and counters. |
void |
ReplManagerPlugin.shutdown(DispatchManager dispatchManager)
|
void |
ReplManagerPlugin.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
ReplManagerPlugin.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
ReplManagerPlugin.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
|
void |
ReplManagerPlugin.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
Uses of DispatchManager in org.xmlBlaster.engine |
---|
Methods in org.xmlBlaster.engine with parameters of type DispatchManager | |
---|---|
protected void |
EventPlugin.callbackStateChange(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
ConnectionStateEnum newState)
|
DispatchConnectionsHandler |
ServerScope.createDispatchConnectionsHandler(DispatchManager dispatchManager)
Returns the callback layer implementation 'CbDispatchConnectionsHandler' on server side. |
void |
EventPlugin.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
EventPlugin.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
EventPlugin.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
|
void |
EventPlugin.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
Uses of DispatchManager in org.xmlBlaster.engine.dispatch |
---|
Constructors in org.xmlBlaster.engine.dispatch with parameters of type DispatchManager | |
---|---|
CbDispatchConnectionsHandler(Global glob,
DispatchManager dispatchManager)
|
Uses of DispatchManager in org.xmlBlaster.engine.distributor.plugins |
---|
Methods in org.xmlBlaster.engine.distributor.plugins that return DispatchManager | |
---|---|
private DispatchManager |
ConsumableQueuePlugin.getDispatchManager(SubscriptionInfo subscriptionInfo)
|
Methods in org.xmlBlaster.engine.distributor.plugins with parameters of type DispatchManager | |
---|---|
void |
ConsumableQueuePlugin.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
Event arriving from one DispatchManager telling this plugin it can start distribute again. |
void |
ConsumableQueuePlugin.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
ConsumableQueuePlugin.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
|
void |
ConsumableQueuePlugin.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
Uses of DispatchManager in org.xmlBlaster.util |
---|
Methods in org.xmlBlaster.util with parameters of type DispatchManager | |
---|---|
DispatchConnectionsHandler |
Global.createDispatchConnectionsHandler(DispatchManager dispatchManager)
Returns the client access layer implementations 'ClientDispatchConnectionsHandler' |
Uses of DispatchManager in org.xmlBlaster.util.dispatch |
---|
Fields in org.xmlBlaster.util.dispatch declared as DispatchManager | |
---|---|
protected DispatchManager |
DispatchConnectionsHandler.dispatchManager
|
private DispatchManager |
DispatchWorker.dispatchManager
|
Methods in org.xmlBlaster.util.dispatch that return DispatchManager | |
---|---|
DispatchManager |
DispatchConnectionsHandler.getDispatchManager()
|
Methods in org.xmlBlaster.util.dispatch with parameters of type DispatchManager | |
---|---|
void |
I_ConnectionStatusListener.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
I_ConnectionStatusListener.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
I_ConnectionStatusListener.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
|
void |
I_ConnectionStatusListener.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
Constructors in org.xmlBlaster.util.dispatch with parameters of type DispatchManager | |
---|---|
DispatchConnectionsHandler(Global glob,
DispatchManager dispatchManager)
You need to call initialize() after construction. |
|
DispatchWorker(Global glob,
DispatchManager mgr)
|
Uses of DispatchManager in org.xmlBlaster.util.dispatch.plugins |
---|
Methods in org.xmlBlaster.util.dispatch.plugins with parameters of type DispatchManager | |
---|---|
void |
I_MsgDispatchInterceptor.addDispatchManager(DispatchManager dispatchManager)
This is called once for each dispatch manager using this plugin. |
boolean |
I_MsgDispatchInterceptor.doActivate(DispatchManager dispatchManager)
If there are new messages available in the queue, you get invoked here and are asked if you want to start a worker thread (from the thread pool) to start taking messages from the queue and send them over the remote connection. |
java.util.List<I_Entry> |
I_MsgDispatchInterceptor.handleNextMessages(DispatchManager dispatchManager,
java.util.List<I_Entry> pushEntries)
If you returned true from doActivate() the worker thread will ask us to retrieve the next messages from the queue (dispatchManager.getQueue()). |
void |
I_MsgDispatchInterceptor.onDispatchWorkerException(DispatchManager dispatchManager,
java.lang.Throwable ex)
Invoked when the dispatching failed due to an exception. |
void |
I_MsgDispatchInterceptor.postHandleNextMessages(DispatchManager dispatchManager,
MsgUnit[] processedEntries)
Method invoked after having successfully sent the entries in asynchronous modus. |
void |
I_MsgDispatchInterceptor.shutdown(DispatchManager dispatchManager)
Deregister the given dispatchManager |
Uses of DispatchManager in org.xmlBlaster.util.dispatch.plugins.prio |
---|
Fields in org.xmlBlaster.util.dispatch.plugins.prio declared as DispatchManager | |
---|---|
private DispatchManager |
DispatchManagerEntry.dispatchManager
|
Methods in org.xmlBlaster.util.dispatch.plugins.prio that return DispatchManager | |
---|---|
DispatchManager |
DispatchManagerEntry.getDispatchManager()
|
Methods in org.xmlBlaster.util.dispatch.plugins.prio with parameters of type DispatchManager | |
---|---|
void |
PriorizedDispatchPlugin.addDispatchManager(DispatchManager dispatchManager)
This is called once for each dispatch manager using this plugin. |
private DispatchManagerEntry |
PriorizedDispatchPlugin.changeManagerState(DispatchManager dispatchManager,
ConnectionStateEnum newState,
boolean flush)
|
boolean |
PriorizedDispatchPlugin.doActivate(DispatchManager dispatchManager)
Called when new messages are available. |
private DispatchManagerEntry |
PriorizedDispatchPlugin.getDispatchManagerEntry(DispatchManager dispatchManager)
|
java.util.List<I_Entry> |
PriorizedDispatchPlugin.handleNextMessages(DispatchManager dispatchManager,
java.util.List<I_Entry> entries)
Enforced by I_MsgDispatchInterceptor. |
void |
PriorizedDispatchPlugin.onDispatchWorkerException(DispatchManager dispatchManager,
java.lang.Throwable ex)
Not doing anything in this method since no Exception handling is done. |
void |
PriorizedDispatchPlugin.postHandleNextMessages(DispatchManager dispatchManager,
MsgUnit[] processedEntries)
Not doing anything in this method since no cleanup needed. |
void |
PriorizedDispatchPlugin.shutdown(DispatchManager dispatchManager)
Deregister a dispatch manager. |
void |
PriorizedDispatchPlugin.toAlive(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
Call by DispatchConnectionsHandler on state transition. |
void |
PriorizedDispatchPlugin.toAliveSync(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
|
void |
PriorizedDispatchPlugin.toDead(DispatchManager dispatchManager,
ConnectionStateEnum oldState,
XmlBlasterException xmlBlasterException)
Call by DispatchConnectionsHandler on state transition Enforced by interface I_ConnectionStatusListener |
void |
PriorizedDispatchPlugin.toPolling(DispatchManager dispatchManager,
ConnectionStateEnum oldState)
Call by DispatchConnectionsHandler on state transition Enforced by interface I_ConnectionStatusListener |
Constructors in org.xmlBlaster.util.dispatch.plugins.prio with parameters of type DispatchManager | |
---|---|
DispatchManagerEntry(DispatchManager dispatchManager)
|
Uses of DispatchManager in org.xmlBlaster.util.error |
---|
Fields in org.xmlBlaster.util.error declared as DispatchManager | |
---|---|
private DispatchManager |
MsgErrorInfo.dispatchManager
|
Methods in org.xmlBlaster.util.error that return DispatchManager | |
---|---|
DispatchManager |
MsgErrorInfo.getDispatchManager()
|
DispatchManager |
I_MsgErrorInfo.getDispatchManager()
Access the DispatchManager which holds the queue. |
Constructors in org.xmlBlaster.util.error with parameters of type DispatchManager | |
---|---|
MsgErrorInfo(Global glob,
MsgQueueEntry[] msgQueueEntries,
DispatchManager dispatchManager,
java.lang.Throwable throwable)
Creates an error info instance for an array of message queue entries |
|
MsgErrorInfo(Global glob,
MsgQueueEntry msgQueueEntry,
DispatchManager dispatchManager,
java.lang.Throwable throwable)
Creates an error info instance with errorCode="internal.unknown" |
|
xmlBlaster 2.0.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |