org.xmlBlaster.protocol.xmlrpc
Class XmlBlasterImpl

java.lang.Object
  org.xmlBlaster.protocol.xmlrpc.XmlBlasterImpl

public class XmlBlasterImpl

extends java.lang.Object

Implements the xmlBlaster server XMLRPC interface. Because the xml-rpc protocol does not recognize user-defined classes, these must be converted to something which xml-rpc does understand. That's why following transformations will take place:

 MsgUnitRaw are converted to Vector
 MsgUnitRaw[] are converted to Vector (of Vector)
 String[] are converted to Vector (of String)
 boolean are converted to int
 void return is not allowed so we return an empty string instead
 

Author:

"Michele Laghi" (michele@laghi.eu)

Field Summary

private AddressServer	addressServer
private I_XmlBlaster	blasterNative
private static java.util.logging.Logger	log

Constructor Summary

XmlBlasterImpl(Global glob, XmlRpcDriver driver, I_XmlBlaster blasterNative)
Constructor.

Method Summary

java.util.Vector	erase(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.util.Vector	get(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access
java.lang.String	ping(java.lang.String qos) Test the xml-rpc connection and if xmlBlaster is available for requests.
java.lang.String	publish(java.lang.String sessionId, java.lang.String xmlKey_literal, byte[] content, java.lang.String publishQos_literal)
java.lang.String	publish(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String content, java.lang.String publishQos_literal) This variant allows to publish simple string based messages (the content is a string).
java.lang.String	publish(java.lang.String sessionId, java.util.Vector msgUnitWrap)
java.util.Vector	publishArr(java.lang.String sessionId, java.util.Vector msgUnitArrWrap)
void	publishOneway(java.lang.String sessionId, java.util.Vector msgUnitArrWrap)
java.lang.String	subscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Subscribe to messages.
java.lang.String	toXml(java.lang.String extraOffset)
java.util.Vector	unSubscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) void return is not allowed so we return an empty string instead

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static java.util.logging.Logger log

blasterNative

private I_XmlBlaster blasterNative

addressServer

private final AddressServer addressServer

Constructor Detail

XmlBlasterImpl

public XmlBlasterImpl(Global glob,
                      XmlRpcDriver driver,
                      I_XmlBlaster blasterNative)
               throws XmlBlasterException

Constructor.

Method Detail

subscribe

public java.lang.String subscribe(java.lang.String sessionId,
                                  java.lang.String xmlKey_literal,
                                  java.lang.String qos_literal)
                           throws XmlBlasterException

Subscribe to messages.

Throws:

XmlBlasterException

See Also:

The interface.subscribe requirement

unSubscribe

public java.util.Vector unSubscribe(java.lang.String sessionId,
                                    java.lang.String xmlKey_literal,
                                    java.lang.String qos_literal)
                             throws XmlBlasterException

void return is not allowed so we return an empty string instead

Throws:

XmlBlasterException

See Also:

CORBA xmlBlaster.idl, The interface.unSubscribe requirement

publish

public java.lang.String publish(java.lang.String sessionId,
                                java.lang.String xmlKey_literal,
                                byte[] content,
                                java.lang.String publishQos_literal)
                         throws XmlBlasterException

Throws:

XmlBlasterException

See Also:

CORBA xmlBlaster.idl, The interface.publish requirement

publish

public java.lang.String publish(java.lang.String sessionId,
                                java.lang.String xmlKey_literal,
                                java.lang.String content,
                                java.lang.String publishQos_literal)
                         throws XmlBlasterException

This variant allows to publish simple string based messages (the content is a string).

Throws:

XmlBlasterException

See Also:

CORBA xmlBlaster.idl, The interface.publish requirement

publish

public java.lang.String publish(java.lang.String sessionId,
                                java.util.Vector msgUnitWrap)
                         throws XmlBlasterException

Throws:

XmlBlasterException

See Also:

CORBA xmlBlaster.idl, The interface.publish requirement

publishArr

public java.util.Vector publishArr(java.lang.String sessionId,
                                   java.util.Vector msgUnitArrWrap)
                            throws XmlBlasterException

Throws:

XmlBlasterException

See Also:

CORBA xmlBlaster.idl, The interface.publish requirement

publishOneway

public void publishOneway(java.lang.String sessionId,
                          java.util.Vector msgUnitArrWrap)

See Also:

CORBA xmlBlaster.idl, The interface.publish requirement

erase

public java.util.Vector erase(java.lang.String sessionId,
                              java.lang.String xmlKey_literal,
                              java.lang.String qos_literal)
                       throws XmlBlasterException

Throws:

XmlBlasterException

See Also:

CORBA xmlBlaster.idl, The interface.erase requirement

get

public java.util.Vector get(java.lang.String sessionId,
                            java.lang.String xmlKey_literal,
                            java.lang.String qos_literal)
                     throws XmlBlasterException

Synchronous access

Returns:

content

Throws:

XmlBlasterException

See Also:

CORBA xmlBlaster.idl, The interface.get requirement

ping

public java.lang.String ping(java.lang.String qos)

Test the xml-rpc connection and if xmlBlaster is available for requests.

See Also:

org.xmlBlaster.protocol.I_XmlBlaster#ping(String)

toXml

public java.lang.String toXml(java.lang.String extraOffset)
                       throws XmlBlasterException

Throws:

XmlBlasterException