org.xmlBlaster.client.dispatch
Class ClientDispatchConnectionsHandler
java.lang.Object
org.xmlBlaster.util.dispatch.DispatchConnectionsHandler
org.xmlBlaster.client.dispatch.ClientDispatchConnectionsHandler
public final class ClientDispatchConnectionsHandler
- extends DispatchConnectionsHandler
Holding all necessary infos to establish a remote
connection and invoke publish(), subscribe(), connect() etc.
- Author:
- xmlBlaster@marcelruff.info
- See Also:
DispatchConnectionsHandler
Field Summary |
java.lang.String |
ME
|
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 |
ME
public final java.lang.String ME
ClientDispatchConnectionsHandler
public ClientDispatchConnectionsHandler(Global glob,
ClientDispatchManager dispatchManager)
throws XmlBlasterException
- Parameters:
dispatchManager
- The message queue witch i belong tocbAddr
- The addresses i shall connect to
- Throws:
XmlBlasterException
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 ClientDispatchConnection instance which has its plugin loaded
- Throws:
XmlBlasterException
createFakedReturnObjects
public void createFakedReturnObjects(I_QueueEntry[] entries,
java.lang.String state,
java.lang.String stateInfo)
throws XmlBlasterException
- 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
- Throws:
XmlBlasterException
filterDistributorEntries
public java.util.ArrayList filterDistributorEntries(java.util.ArrayList entries,
java.lang.Throwable ex)
- Specified by:
filterDistributorEntries
in class DispatchConnectionsHandler
Copyright © 1999-2014 The xmlBlaster.org contributers.