Uses of Interface
org.xmlBlaster.util.dispatch.I_DispatchManager

Packages that use I_DispatchManager

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.dispatch
org.xmlBlaster.util.dispatch.plugins
org.xmlBlaster.util.dispatch.plugins.prio
org.xmlBlaster.util.error

Uses of I_DispatchManager in org.xmlBlaster.client

Fields in org.xmlBlaster.client declared as I_DispatchManager

private I_DispatchManager

XmlBlasterAccess.dispatchManager The dispatcher framework

Methods in org.xmlBlaster.client with parameters of type I_DispatchManager

void	XmlBlasterAccess.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState) Call by DispatchManager on connection state transition.
void	XmlBlasterAccess.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	XmlBlasterAccess.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException) Call by DispatchManager on connection state transition.
void	XmlBlasterAccess.toPolling(I_DispatchManager dispatchManager, ConnectionStateEnum oldState) Call by DispatchManager on connection state transition.

Uses of I_DispatchManager in org.xmlBlaster.client.dispatch

Classes in org.xmlBlaster.client.dispatch that implement I_DispatchManager

class

ClientDispatchManager Manages the sending of messages and commands and does error recovery further we communicate with the dispatcher plugin if one is configured.

Uses of I_DispatchManager in org.xmlBlaster.contrib.mime

Methods in org.xmlBlaster.contrib.mime with parameters of type I_DispatchManager

void	DropIfNotDeliverable.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	DropIfNotDeliverableUniqueOnly.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	DropIfNotDeliverable.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	DropIfNotDeliverableUniqueOnly.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	DropIfNotDeliverable.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	DropIfNotDeliverableUniqueOnly.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	DropIfNotDeliverable.toPolling(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	DropIfNotDeliverableUniqueOnly.toPolling(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)

Uses of I_DispatchManager in org.xmlBlaster.contrib.replication.impl

Methods in org.xmlBlaster.contrib.replication.impl with parameters of type I_DispatchManager

void	ReplManagerPlugin.addDispatchManager(I_DispatchManager dispatchManager) This method is invoked always so see sessionAdded javadoc.
boolean	ReplManagerPlugin.doActivate(I_DispatchManager dispatchManager)
java.util.List<I_Entry>	ReplManagerPlugin.handleNextMessages(I_DispatchManager dispatchManager, java.util.List<I_Entry> pushEntries)
void	ReplManagerPlugin.onDispatchWorkerException(I_DispatchManager dispatchManager, java.lang.Throwable ex)
void	ReplManagerPlugin.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Does cleanup, particularly it sets the status and counters.
void	ReplManagerPlugin.shutdown(I_DispatchManager dispatchManager)
void	ReplManagerPlugin.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	ReplManagerPlugin.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	ReplManagerPlugin.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	ReplManagerPlugin.toPolling(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)

Uses of I_DispatchManager in org.xmlBlaster.engine

Methods in org.xmlBlaster.engine with parameters of type I_DispatchManager

protected void	EventPlugin.callbackStateChange(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, ConnectionStateEnum newState)
void	EventPlugin.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	EventPlugin.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	EventPlugin.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	EventPlugin.toPolling(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)

Uses of I_DispatchManager in org.xmlBlaster.engine.dispatch

Classes in org.xmlBlaster.engine.dispatch that implement I_DispatchManager

class

ServerDispatchManager Manages the sending of messages and commands and does error recovery further we communicate with the dispatcher plugin if one is configured.

Uses of I_DispatchManager in org.xmlBlaster.engine.distributor.plugins

Methods in org.xmlBlaster.engine.distributor.plugins that return I_DispatchManager

private I_DispatchManager

ConsumableQueuePlugin.getDispatchManager(SubscriptionInfo subscriptionInfo)

Methods in org.xmlBlaster.engine.distributor.plugins with parameters of type I_DispatchManager

void	ConsumableQueuePlugin.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState) Event arriving from one DispatchManager telling this plugin it can start distribute again.
void	ConsumableQueuePlugin.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	ConsumableQueuePlugin.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	ConsumableQueuePlugin.toPolling(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)

Uses of I_DispatchManager in org.xmlBlaster.util.dispatch

Fields in org.xmlBlaster.util.dispatch declared as I_DispatchManager

protected I_DispatchManager	DispatchConnectionsHandler.dispatchManager
private I_DispatchManager	DispatchWorker.dispatchManager

Methods in org.xmlBlaster.util.dispatch that return I_DispatchManager

I_DispatchManager

DispatchConnectionsHandler.getDispatchManager()

Methods in org.xmlBlaster.util.dispatch with parameters of type I_DispatchManager

void	I_ConnectionStatusListener.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	I_ConnectionStatusListener.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	I_ConnectionStatusListener.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	I_ConnectionStatusListener.toPolling(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)

Constructors in org.xmlBlaster.util.dispatch with parameters of type I_DispatchManager

DispatchConnectionsHandler(Global glob, I_DispatchManager dispatchManager)
You need to call initialize() after construction.

DispatchWorker(Global glob, I_DispatchManager mgr)

Uses of I_DispatchManager in org.xmlBlaster.util.dispatch.plugins

Methods in org.xmlBlaster.util.dispatch.plugins with parameters of type I_DispatchManager

void	I_MsgDispatchInterceptor.addDispatchManager(I_DispatchManager dispatchManager) This is called once for each dispatch manager using this plugin.
boolean	I_MsgDispatchInterceptor.doActivate(I_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(I_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(I_DispatchManager dispatchManager, java.lang.Throwable ex) Invoked when the dispatching failed due to an exception.
void	I_MsgDispatchInterceptor.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Method invoked after having successfully sent the entries in asynchronous modus.
void	I_MsgDispatchInterceptor.shutdown(I_DispatchManager dispatchManager) Deregister the given dispatchManager

Uses of I_DispatchManager in org.xmlBlaster.util.dispatch.plugins.prio

Fields in org.xmlBlaster.util.dispatch.plugins.prio declared as I_DispatchManager

private I_DispatchManager

DispatchManagerEntry.dispatchManager

Methods in org.xmlBlaster.util.dispatch.plugins.prio that return I_DispatchManager

I_DispatchManager

DispatchManagerEntry.getDispatchManager()

Methods in org.xmlBlaster.util.dispatch.plugins.prio with parameters of type I_DispatchManager

void	PriorizedDispatchPlugin.addDispatchManager(I_DispatchManager dispatchManager) This is called once for each dispatch manager using this plugin.
private DispatchManagerEntry	PriorizedDispatchPlugin.changeManagerState(I_DispatchManager dispatchManager, ConnectionStateEnum newState, boolean flush)
boolean	PriorizedDispatchPlugin.doActivate(I_DispatchManager dispatchManager) Called when new messages are available.
private DispatchManagerEntry	PriorizedDispatchPlugin.getDispatchManagerEntry(I_DispatchManager dispatchManager)
java.util.List<I_Entry>	PriorizedDispatchPlugin.handleNextMessages(I_DispatchManager dispatchManager, java.util.List<I_Entry> entries) Enforced by I_MsgDispatchInterceptor.
void	PriorizedDispatchPlugin.onDispatchWorkerException(I_DispatchManager dispatchManager, java.lang.Throwable ex) Not doing anything in this method since no Exception handling is done.
void	PriorizedDispatchPlugin.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Not doing anything in this method since no cleanup needed.
void	PriorizedDispatchPlugin.shutdown(I_DispatchManager dispatchManager) Deregister a dispatch manager.
void	PriorizedDispatchPlugin.toAlive(I_DispatchManager dispatchManager, ConnectionStateEnum oldState) Call by DispatchConnectionsHandler on state transition.
void	PriorizedDispatchPlugin.toAliveSync(I_DispatchManager dispatchManager, ConnectionStateEnum oldState)
void	PriorizedDispatchPlugin.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException) Call by DispatchConnectionsHandler on state transition Enforced by interface I_ConnectionStatusListener
void	PriorizedDispatchPlugin.toPolling(I_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 I_DispatchManager

DispatchManagerEntry(I_DispatchManager dispatchManager)

Uses of I_DispatchManager in org.xmlBlaster.util.error

Fields in org.xmlBlaster.util.error declared as I_DispatchManager

private I_DispatchManager

MsgErrorInfo.dispatchManager

Methods in org.xmlBlaster.util.error that return I_DispatchManager

I_DispatchManager	I_MsgErrorInfo.getDispatchManager() Access the DispatchManager which holds the queue.
I_DispatchManager	MsgErrorInfo.getDispatchManager()

Constructors in org.xmlBlaster.util.error with parameters of type I_DispatchManager

MsgErrorInfo(Global glob, MsgQueueEntry[] msgQueueEntries, I_DispatchManager dispatchManager, java.lang.Throwable throwable)
Creates an error info instance for an array of message queue entries

MsgErrorInfo(Global glob, MsgQueueEntry msgQueueEntry, I_DispatchManager dispatchManager, java.lang.Throwable throwable)
Creates an error info instance with errorCode="internal.unknown"