|
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.engine.XmlBlasterImpl
public class XmlBlasterImpl
This is the native implementation of the xmlBlaster interface.
All protocol drivers access xmlBlaster through these methods.
RequestBroker
,
I_XmlBlaster
Field Summary | |
---|---|
private Authenticate |
authenticate
|
private AvailabilityChecker |
availabilityChecker
|
private byte[] |
EMPTY_BYTEARR
|
private ServerScope |
glob
|
private static java.util.logging.Logger |
log
|
private java.lang.String |
ME
|
private RequestBroker |
requestBroker
|
Constructor Summary | |
---|---|
XmlBlasterImpl(Authenticate authenticate)
One instance of this represents one xmlBlaster server. |
Method Summary | |
---|---|
java.lang.String[] |
erase(AddressServer addressServer,
java.lang.String sessionId,
java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Delete messages. |
MsgUnitRaw[] |
get(AddressServer addressServer,
java.lang.String sessionId,
java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Synchronous access a message. |
Destination |
getDestination(MsgUnit msgUnit)
|
private MsgUnit |
importAndAuthorize(SessionInfo sessionInfo,
AddressServer addressServer,
MsgUnitRaw msgUnitRaw,
MethodName action)
Check message via security plugin. |
private java.lang.String |
interceptExeptionByAuthorizer(java.lang.Throwable e,
SessionInfo sessionInfo,
AddressServer addressServer,
MsgUnit msgUnit,
MethodName action)
|
java.lang.String |
ping(AddressServer addressServer,
java.lang.String qos)
ping xmlBlaster if everything is OK and if xmlBlaster is willing to accept requests. |
private java.lang.String |
publish(AddressServer addressServer,
SessionInfo sessionInfo,
MsgUnitRaw msgUnitRaw,
MethodName methodName)
|
java.lang.String |
publish(AddressServer addressServer,
java.lang.String sessionId,
MsgUnitRaw msgUnitRaw)
Publish a message. |
java.lang.String[] |
publishArr(AddressServer addressServer,
java.lang.String sessionId,
MsgUnitRaw[] msgUnitArr)
Publish messages. |
void |
publishOneway(AddressServer addressServer,
java.lang.String sessionId,
MsgUnitRaw[] msgUnitArr)
Publish messages. |
void |
shutdown()
|
java.lang.String |
subscribe(AddressServer addressServer,
java.lang.String sessionId,
java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Subscribe to messages. |
java.lang.String |
toXml()
Dump state of RequestBroker into a XML ASCII string. |
java.lang.String |
toXml(java.lang.String extraOffset)
Dump state of RequestBroker into a XML ASCII string. |
java.lang.String[] |
unSubscribe(AddressServer addressServer,
java.lang.String sessionId,
java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Unsubscribe from messages. |
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 RequestBroker requestBroker
private final Authenticate authenticate
private final AvailabilityChecker availabilityChecker
private final ServerScope glob
private static java.util.logging.Logger log
private final byte[] EMPTY_BYTEARR
Constructor Detail |
---|
public XmlBlasterImpl(Authenticate authenticate) throws XmlBlasterException
authenticate
- The authentication service
XmlBlasterException
Method Detail |
---|
public final java.lang.String subscribe(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
subscribe
in interface I_XmlBlaster
xmlKey_literal
- Depending on the security plugin this key is encryptedqos_literal
- Depending on the security plugin this qos is encrypted
XmlBlasterException
RequestBroker
public final java.lang.String[] unSubscribe(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
unSubscribe
in interface I_XmlBlaster
xmlKey_literal
- Depending on the security plugin this key is encrypted
XmlBlasterException
RequestBroker
public final java.lang.String publish(AddressServer addressServer, java.lang.String sessionId, MsgUnitRaw msgUnitRaw) throws XmlBlasterException
publish
in interface I_XmlBlaster
msgUnitRaw
- The MsgUnitRaw contains the literal ASCII strings of xmlKey and publishQos and the binary content.
Depending on the security plugin the msgUnit is encrypted
XmlBlasterException
RequestBroker
private final java.lang.String publish(AddressServer addressServer, SessionInfo sessionInfo, MsgUnitRaw msgUnitRaw, MethodName methodName) throws XmlBlasterException
XmlBlasterException
public final java.lang.String[] publishArr(AddressServer addressServer, java.lang.String sessionId, MsgUnitRaw[] msgUnitArr) throws XmlBlasterException
publishArr
in interface I_XmlBlaster
XmlBlasterException
RequestBroker
public final void publishOneway(AddressServer addressServer, java.lang.String sessionId, MsgUnitRaw[] msgUnitArr)
publishOneway
in interface I_XmlBlaster
RequestBroker
public final java.lang.String[] erase(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
erase
in interface I_XmlBlaster
XmlBlasterException
RequestBroker
public final MsgUnitRaw[] get(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
get
in interface I_XmlBlaster
XmlBlasterException
RequestBroker
public final java.lang.String toXml() throws XmlBlasterException
toXml
in interface I_XmlBlaster
XmlBlasterException
public final java.lang.String toXml(java.lang.String extraOffset) throws XmlBlasterException
toXml
in interface I_XmlBlaster
extraOffset
- indenting of tags for nice output
XmlBlasterException
private java.lang.String interceptExeptionByAuthorizer(java.lang.Throwable e, SessionInfo sessionInfo, AddressServer addressServer, MsgUnit msgUnit, MethodName action)
sessionInfo
- addressServer
- msgUnit
- action
-
public Destination getDestination(MsgUnit msgUnit)
private MsgUnit importAndAuthorize(SessionInfo sessionInfo, AddressServer addressServer, MsgUnitRaw msgUnitRaw, MethodName action) throws XmlBlasterException
sessionInfo
- The sessionInfo (we are already authenticated)addressServer
- The server side protocol plugin information (like IP and port)MsgUnit
- The message, probably encryptedString
- actionKey (eg. PUBLISH, GET, ...)
XmlBlasterException
- Thrown if seal/signature checks fail, the identity in unknown
or the message format has errors.public final java.lang.String ping(AddressServer addressServer, java.lang.String qos) throws XmlBlasterException
ping
in interface I_XmlBlaster
qos
- Currently an empty string ""
XmlBlasterException
AvailabilityChecker.getStatus(String)
public final void shutdown()
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |