|
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.protocol.xmlrpc.CallbackXmlRpcDriverSingleChannel
public class CallbackXmlRpcDriverSingleChannel
This object sends a MsgUnitRaw back to a client using XMLRPC interface, in the same JVM.
The I_CallbackDriver.update() method of the client will be invoked
XmlRpcDriver
Field Summary | |
---|---|
private java.util.concurrent.LinkedBlockingQueue<UpdateEvent> |
ackQueue
|
private CallbackAddress |
callbackAddress
|
private long |
counter
|
private java.lang.Thread |
currentThread
|
private Global |
glob
|
private java.lang.String |
lastRespanLocation
|
private static java.util.logging.Logger |
log
|
private java.lang.String |
ME
|
private java.lang.String |
sessionId
|
private Timestamp |
timestamp
|
private long |
updateAckTimeout
|
private java.util.concurrent.LinkedBlockingQueue<UpdateEvent> |
updateQueue
|
private long |
updateTimeout
|
private java.lang.ref.WeakReference<XmlBlasterImpl> |
xblImpl
|
Constructor Summary | |
---|---|
CallbackXmlRpcDriverSingleChannel()
|
Method Summary | |
---|---|
java.util.concurrent.LinkedBlockingQueue<UpdateEvent> |
getAckQueue()
|
java.lang.String |
getName()
Get a human readable name of this driver |
long |
getPingInterval()
|
java.lang.String |
getProtocolId()
Access the xmlBlaster internal name of the protocol driver. |
java.lang.String |
getRawAddress()
Get the address how to access this driver. |
java.lang.String |
getType()
Enforced by I_Plugin |
java.util.concurrent.LinkedBlockingQueue<UpdateEvent> |
getUpdateQueue()
|
java.lang.String |
getVersion()
Enforced by I_Plugin |
void |
init(Global global,
CallbackAddress cbAddress)
Get callback reference here. |
void |
init(Global glob,
PluginInfo pluginInfo)
This method is called by the PluginManager (enforced by I_Plugin). |
void |
interrupt()
|
boolean |
isAlive()
|
java.lang.String |
ping(java.lang.String qos)
Ping to check if callback server is alive. |
void |
register(java.lang.String sessionId_,
XmlBlasterImpl xblImpl_)
|
I_ProgressListener |
registerProgressListener(I_ProgressListener listener)
Register a listener for to receive information about the progress of incoming data. |
void |
respan(java.lang.String location)
|
java.lang.String[] |
sendUpdate(MsgUnitRaw[] msgArr)
This sends the update to the client. |
void |
sendUpdateOneway(MsgUnitRaw[] msgArr)
The oneway variant, without return value. |
void |
setCurrentThread(java.lang.Thread currThread)
|
void |
shutdown()
This method shuts down the driver. |
void |
timeout(java.lang.Object userData)
You will be notified about the timeout through this method. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private java.lang.String ME
private Global glob
private static java.util.logging.Logger log
private CallbackAddress callbackAddress
private java.lang.String sessionId
private java.util.concurrent.LinkedBlockingQueue<UpdateEvent> updateQueue
private java.util.concurrent.LinkedBlockingQueue<UpdateEvent> ackQueue
private long updateAckTimeout
private long updateTimeout
private long counter
private java.lang.ref.WeakReference<XmlBlasterImpl> xblImpl
private Timestamp timestamp
private java.lang.Thread currentThread
private java.lang.String lastRespanLocation
Constructor Detail |
---|
public CallbackXmlRpcDriverSingleChannel()
Method Detail |
---|
public java.lang.String getName()
getName
in interface I_CallbackDriver
public java.lang.String getProtocolId()
getProtocolId
in interface I_CallbackDriver
public java.lang.String getType()
getType
in interface I_Plugin
public java.lang.String getVersion()
getVersion
in interface I_Plugin
public void init(Global glob, PluginInfo pluginInfo)
init
in interface I_Plugin
I_Plugin.init(org.xmlBlaster.util.Global,org.xmlBlaster.util.plugin.PluginInfo)
public java.lang.String getRawAddress()
getRawAddress
in interface I_CallbackDriver
public void register(java.lang.String sessionId_, XmlBlasterImpl xblImpl_) throws XmlBlasterException
XmlBlasterException
public void init(Global global, CallbackAddress cbAddress) throws XmlBlasterException
init
in interface I_CallbackDriver
callbackAddress
- Contains the stringified XMLRPC callback handle of
the client
XmlBlasterException
public final java.lang.String[] sendUpdate(MsgUnitRaw[] msgArr) throws XmlBlasterException
sendUpdate
in interface I_CallbackDriver
msgArr
- Array of all messages to send, is guaranteed to never be null
<qos> <state id='OK'/> </qos>
e.id="CallbackFailed",
- should be caught and handled appropriate
XmlBlasterException
public void sendUpdateOneway(MsgUnitRaw[] msgArr) throws XmlBlasterException
sendUpdateOneway
in interface I_CallbackDriver
msgArr
- Array of all messages to send, is guaranteed to never be null
XmlBlasterException
- Is never from the client (oneway).public final void respan(java.lang.String location) throws XmlBlasterException
XmlBlasterException
public final long getPingInterval()
public final java.lang.String ping(java.lang.String qos) throws XmlBlasterException
ping
in interface I_CallbackDriver
qos
- Currently an empty string ""
XmlBlasterException
- If client not reachableorg.xmlBlaster.protocol.I_XmlBlaster#ping(String)
public I_ProgressListener registerProgressListener(I_ProgressListener listener)
I_CallbackDriver
registerProgressListener
in interface I_CallbackDriver
listener
- Your listener, pass 0 to unregister.
public void shutdown()
shutdown
in interface I_Plugin
public boolean isAlive()
isAlive
in interface I_CallbackDriver
public java.util.concurrent.LinkedBlockingQueue<UpdateEvent> getUpdateQueue()
public java.util.concurrent.LinkedBlockingQueue<UpdateEvent> getAckQueue()
public void timeout(java.lang.Object userData)
I_Timeout
timeout
in interface I_Timeout
userData
- You get bounced back your userData which you passed
with Timeout.addTimeoutListener()public void setCurrentThread(java.lang.Thread currThread)
public void interrupt()
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |