|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.util.protocol.RequestReplyExecutor org.xmlBlaster.util.protocol.socket.SocketExecutor org.xmlBlaster.protocol.socket.SocketCbConnection
public class SocketCbConnection
This instance establishes exactly one connection to a listening client side callback server.
NOTE: First step for a different SOCKET connection on callback NOTE: This code is currently NOT in use (as we reuse the same SOCKET with CallbackSocketDriver.java)
Field Summary | |
---|---|
protected java.lang.String |
cbSessionId
The unique client cbSessionId |
protected CallbackAddress |
clientAddress
|
private Global |
glob
|
private static java.util.logging.Logger |
log
|
private java.lang.String |
ME
|
protected java.net.Socket |
sock
The socket connection to one client |
private SocketUrl |
socketUrl
Holds the hostname/port of the callback server running on client side to which we want connect |
Fields inherited from class org.xmlBlaster.util.protocol.socket.SocketExecutor |
---|
iStream, loginName, maxChunkSize, msgInfoParserClassName, oStream, running, soLingerTimeout, soTimeout |
Fields inherited from class org.xmlBlaster.util.protocol.RequestReplyExecutor |
---|
addressConfig, addressServer, cbClient, compressZlib, compressZlibStream, contextNode, mbeanHandle, minSizeForCompression, ONEWAY, pingResponseTimeout, prefix, progressListener, responseListenerMap, responseTimeout, updateResponseTimeout, useEmailExpiryTimestamp, WAIT_ON_RESPONSE |
Constructor Summary | |
---|---|
SocketCbConnection(Global glob)
Connect to xmlBlaster using plain socket with native message format. |
Method Summary | |
---|---|
void |
connectLowlevel(CallbackAddress callbackAddress)
Connects to clients callback server with one socket connection. |
(package private) Global |
getGlobal()
|
java.lang.String |
getLocalAddress()
A string with the local address and port (the xmlBlaster side). |
java.lang.String |
getProtocol()
Returns the protocol type. |
java.net.Socket |
getSocket()
Get the raw socket handle |
java.lang.String |
getType()
The protocol type, used for logging |
boolean |
isConnected()
|
java.lang.String |
ping(java.lang.String qos)
Check the clients cb server. |
void |
resetConnection()
Reset the driver on problems |
void |
shutdown()
Shut down the callback server. |
java.lang.String |
toXml()
Dump of the state, remove in future. |
java.lang.String |
toXml(java.lang.String extraOffset)
Dump of the state, remove in future. |
Methods inherited from class org.xmlBlaster.util.protocol.socket.SocketExecutor |
---|
getCbMsgInfoParserClassName, getGlobalKey, getInputStream, getMsgInfoParserClassName, getOutputStream, getSoLingerTimeout, getSoTimeout, getUsageUrl, getVersion, initialize, sendMessage, sendUpdate, setLoginName, setRunning, setSoLingerTimeout, setSoTimeout, setUsageUrl, usage, useUdpForOneway |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.xmlBlaster.util.protocol.RequestReplyExecutorMBean |
---|
getMinSizeForCompression, getPingResponseTimeout, getResponseTimeout, getResponseTimeout, getUpdateResponseTimeout, interruptInvocation, isCompressZlib, isCompressZlibStream, isUseEmailExpiryTimestamp, setCompressZlib, setCompressZlibStream, setMinSizeForCompression, setPingResponseTimeout, setResponseTimeout, setUpdateResponseTimeout, setUseEmailExpiryTimestamp |
Methods inherited from interface org.xmlBlaster.util.admin.I_AdminPlugin |
---|
isShutdown |
Field Detail |
---|
private java.lang.String ME
private Global glob
private static java.util.logging.Logger log
private SocketUrl socketUrl
protected java.net.Socket sock
protected java.lang.String cbSessionId
protected CallbackAddress clientAddress
Constructor Detail |
---|
public SocketCbConnection(Global glob) throws XmlBlasterException
XmlBlasterException
Method Detail |
---|
public java.net.Socket getSocket() throws XmlBlasterException
XmlBlasterException
final Global getGlobal()
public java.lang.String getType()
RequestReplyExecutor
getType
in interface I_AdminPlugin
getType
in class RequestReplyExecutor
public void connectLowlevel(CallbackAddress callbackAddress) throws XmlBlasterException
XmlBlasterException
public void resetConnection()
public java.lang.String getLocalAddress()
public final java.lang.String getProtocol()
public void shutdown()
shutdown
in interface I_AdminPlugin
shutdown
in class SocketExecutor
public final boolean isConnected()
public final java.lang.String ping(java.lang.String qos) throws XmlBlasterException
ping
in class SocketExecutor
qos
- Currently an empty string ""
XmlBlasterException
- If client not reachablepublic java.lang.String toXml() throws XmlBlasterException
XmlBlasterException
public java.lang.String toXml(java.lang.String extraOffset) throws XmlBlasterException
XmlBlasterException
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |