Uses of Class
org.xmlBlaster.util.dispatch.DispatchManager

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"