org.xmlBlaster.engine.dispatch
Class CbDispatchConnectionsHandler

java.lang.Object
  org.xmlBlaster.util.dispatch.DispatchConnectionsHandler
      org.xmlBlaster.engine.dispatch.CbDispatchConnectionsHandler

public final class CbDispatchConnectionsHandler
extends DispatchConnectionsHandler

Holding all necessary infos to establish a remote connection and invoke update()/updateOneway()/ping().

Author:

xmlBlaster@marcelruff.info

See Also:

DispatchConnectionsHandler

Field Summary

private static java.util.logging.Logger	log
java.lang.String	ME

Fields inherited from class org.xmlBlaster.util.dispatch.DispatchConnectionsHandler

dispatchManager, glob, postSendListener, statistic

Constructor Summary

CbDispatchConnectionsHandler(Global glob, ServerDispatchManager dispatchManager)

Method Summary

DispatchConnection	createDispatchConnection(AddressBase address) Create a DispatchConnection instance and load the protocol plugin.
void	createFakedReturnObjects(I_QueueEntry[] entries, java.lang.String state, java.lang.String stateInfo) If no connection is available but the message is for example save queued, we can generate here valid return objects
java.util.ArrayList	filterDistributorEntries(java.util.ArrayList entries, java.lang.Throwable ex) Scans through the entries array for such messages which want an async notification and sends such a notification.
boolean	isUserThread()

Methods inherited from class org.xmlBlaster.util.dispatch.DispatchConnectionsHandler

addDispatchConnection, clearDispatchConnectionList, getAliveAddress, getAliveDispatchConnection, getCountDispatchConnection, getCurrentDispatchConnection, getDeadAddress, getDeadDispatchConnection, getDispatchConnectionArr, getDispatchManager, getDispatchStatistic, getPollingDispatchConnection, getPostSendListener, getState, initialize, isAlive, isDead, isPolling, isUndef, registerPostSendListener, send, shutdown, toXml

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static java.util.logging.Logger log

ME

public final java.lang.String ME

Constructor Detail

CbDispatchConnectionsHandler

public CbDispatchConnectionsHandler(Global glob,
                                    ServerDispatchManager dispatchManager)
                             throws XmlBlasterException

Parameters:

dispatchManager - The message queue witch i belong to

cbAddr - The addresses i shall connect to

Throws:

XmlBlasterException

Method Detail

isUserThread

public boolean isUserThread()

Specified by:

isUserThread in class DispatchConnectionsHandler

createDispatchConnection

public DispatchConnection createDispatchConnection(AddressBase address)
                                            throws XmlBlasterException

Description copied from class: DispatchConnectionsHandler

Create a DispatchConnection instance and load the protocol plugin. You should call initialie() later.

Specified by:

createDispatchConnection in class DispatchConnectionsHandler

Returns:

a new CbDispatchConnection instance which has its plugin loaded

Throws:

XmlBlasterException

createFakedReturnObjects

public void createFakedReturnObjects(I_QueueEntry[] entries,
                                     java.lang.String state,
                                     java.lang.String stateInfo)

If no connection is available but the message is for example save queued, we can generate here valid return objects

Specified by:

createFakedReturnObjects in class DispatchConnectionsHandler

Parameters:

state - e.g. Constants.STATE_OK

filterDistributorEntries

public java.util.ArrayList filterDistributorEntries(java.util.ArrayList entries,
                                                    java.lang.Throwable ex)

Scans through the entries array for such messages which want an async notification and sends such a notification.

Specified by:

filterDistributorEntries in class DispatchConnectionsHandler

Parameters:

entries -

Returns:

The MsgQueueEntry objects (as an ArrayList) which did not want such an async notification. This is needed to allow the core process such messages the normal way.