|
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.corba.ServerImpl
public class ServerImpl
Implements the xmlBlaster server CORBA interface.
RequestBroker
Field Summary | |
---|---|
private AddressServer |
addressServer
|
private I_XmlBlaster |
blaster
|
private Global |
glob
|
private static java.util.logging.Logger |
log
|
private java.lang.String |
ME
|
private org.omg.CORBA.ORB |
orb
|
Constructor Summary | |
---|---|
ServerImpl(Global glob,
org.omg.CORBA.ORB orb,
AddressServer addressServer,
I_XmlBlaster blaster)
Construct a persistently named object. |
Method Summary | |
---|---|
static java.lang.String |
convert(byte[] objectId)
Converts an oid into a string as a hex dump with an unique identifier "IIOP:" in front. |
java.lang.String[] |
erase(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
|
MessageUnit[] |
get(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Synchronous access |
private java.lang.String |
getSecretSessionId()
Extract the user session ID from POA. |
I_XmlBlaster |
getXmlBlaster()
Get a handle on the request broker singleton (the engine of xmlBlaster). |
java.lang.String |
ping(java.lang.String qos)
Ping to check if xmlBlaster is alive. |
java.lang.String |
publish(MessageUnit msgUnit)
|
java.lang.String[] |
publishArr(MessageUnit[] msgUnitArr)
|
void |
publishOneway(MessageUnit[] msgUnitArr)
|
java.lang.String |
subscribe(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Subscribe to messages |
java.lang.String[] |
unSubscribe(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private final java.lang.String ME
private final Global glob
private static java.util.logging.Logger log
private final org.omg.CORBA.ORB orb
private final I_XmlBlaster blaster
private final AddressServer addressServer
Constructor Detail |
---|
public ServerImpl(Global glob, org.omg.CORBA.ORB orb, AddressServer addressServer, I_XmlBlaster blaster) throws XmlBlasterException
XmlBlasterException
Method Detail |
---|
public I_XmlBlaster getXmlBlaster()
public java.lang.String subscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
subscribe
in interface ServerOperations
XmlBlasterException
public java.lang.String[] unSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
unSubscribe
in interface ServerOperations
XmlBlasterException
public java.lang.String publish(MessageUnit msgUnit) throws XmlBlasterException
publish
in interface ServerOperations
XmlBlasterException
public java.lang.String[] publishArr(MessageUnit[] msgUnitArr) throws XmlBlasterException
publishArr
in interface ServerOperations
XmlBlasterException
public void publishOneway(MessageUnit[] msgUnitArr)
publishOneway
in interface ServerOperations
public java.lang.String[] erase(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
erase
in interface ServerOperations
XmlBlasterException
public MessageUnit[] get(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
get
in interface ServerOperations
XmlBlasterException
private java.lang.String getSecretSessionId() throws XmlBlasterException
XmlBlasterException
public static final java.lang.String convert(byte[] objectId)
public java.lang.String ping(java.lang.String qos)
ping
in interface ServerOperations
org.xmlBlaster.protocol.I_XmlBlaster#ping(String)
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |