|
xmlBlaster 2.2.0 client API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.util.dispatch.DispatchConnection org.xmlBlaster.client.dispatch.ClientDispatchConnection
public final class ClientDispatchConnection
Holding all necessary infos to establish callback connections and invoke their update().
DispatchConnection
Field Summary |
---|
Fields inherited from class org.xmlBlaster.util.dispatch.DispatchConnection |
---|
address, connectionsHandler, glob, myId, physicalConnectionOk, PING_THREAD_NAME, previousBytesRead, previousBytesWritten, retryCounter, serverAcceptsRequests, state |
Constructor Summary | |
---|---|
ClientDispatchConnection(Global glob,
ClientDispatchConnectionsHandler connectionsHandler,
AddressBase address)
|
Method Summary | |
---|---|
void |
connectLowlevel()
Connect on protocol layer and try an initial low level ping. |
java.lang.String |
doPing(java.lang.String data)
Does the real ping to the remote server instance. |
void |
doSend(MsgQueueEntry[] msgArr_,
boolean isAsyncMode)
Send the messages to xmlBlaster. |
protected boolean |
forcePingFailure()
|
java.lang.String |
getDriverName()
A human readable name of the protocol plugin |
java.lang.String |
getName()
|
void |
loadPlugin()
Load the appropriate protocol driver, e.g the CORBA protocol plugin. |
protected void |
reconnect()
On reconnect polling try to establish the connection. |
I_ProgressListener |
registerProgressListener(I_ProgressListener listener)
Should be overwritten by extending classes. |
void |
resetConnection()
Nothing to do here |
void |
shutdown(boolean delayed)
Stop all callback drivers of this client. |
java.lang.String |
toXml(java.lang.String extraOffset)
Dump state of this object into a XML ASCII string. |
Methods inherited from class org.xmlBlaster.util.dispatch.DispatchConnection |
---|
finalize, getAddress, getState, handleTransition, initialize, isAlive, isConnectionWasDown, isDead, isPolling, isUndef, ping, ping, send, setAddress, setConnectionWasDown, spanPingTimer, timeout |
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ClientDispatchConnection(Global glob, ClientDispatchConnectionsHandler connectionsHandler, AddressBase address) throws XmlBlasterException
connectionsHandler
- The DevliveryConnectionsHandler witch i belong toaAddress
- The address i shall connect to
XmlBlasterException
Method Detail |
---|
public final java.lang.String getDriverName()
DispatchConnection
getDriverName
in class DispatchConnection
public final java.lang.String getName()
getName
in class DispatchConnection
public final void loadPlugin() throws XmlBlasterException
This method is called by our base class during initialization.
loadPlugin
in class DispatchConnection
XmlBlasterException
public final void connectLowlevel() throws XmlBlasterException
DispatchConnection
connectLowlevel
in class DispatchConnection
XmlBlasterException
- with ErrorCode.COMMUNICATION* if server is not reachable
or other exceptions on other errorsDispatchConnection.connectLowlevel()
public void doSend(MsgQueueEntry[] msgArr_, boolean isAsyncMode) throws XmlBlasterException
doSend
in class DispatchConnection
msgArr
- The messages to send.
msgArr[i].getReturnVal() will contain the returned QoS object or null for oneway operationsisAsyncMode
- true if coming from queue
XmlBlasterException
public final java.lang.String doPing(java.lang.String data) throws XmlBlasterException
DispatchConnection
doPing
in class DispatchConnection
data
- QoS, never null
XmlBlasterException
DispatchConnection.doPing(String)
public final void resetConnection()
resetConnection
in class DispatchConnection
protected final void reconnect() throws XmlBlasterException
reconnect
in class DispatchConnection
XmlBlasterException
public final void shutdown(boolean delayed) throws XmlBlasterException
shutdown
in class DispatchConnection
XmlBlasterException
public final java.lang.String toXml(java.lang.String extraOffset)
toXml
in class DispatchConnection
extraOffset
- indenting of tags for nice output
public I_ProgressListener registerProgressListener(I_ProgressListener listener)
DispatchConnection
registerProgressListener
in class DispatchConnection
protected boolean forcePingFailure()
forcePingFailure
in class DispatchConnection
|
xmlBlaster 2.2.0 client API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |