xmlBlaster 2.1.0 API

org.xmlBlaster.client.dispatch
Class ClientDispatchConnectionsHandler

java.lang.Object
  extended by org.xmlBlaster.util.dispatch.DispatchConnectionsHandler
      extended by 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
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
ClientDispatchConnectionsHandler(Global glob, ClientDispatchManager 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)
           
 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

ClientDispatchConnectionsHandler

public ClientDispatchConnectionsHandler(Global glob,
                                        ClientDispatchManager 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 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

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.