org.xmlBlaster.protocol.rmi
Class XmlBlasterImpl

java.lang.Object
  java.rmi.server.RemoteObject
      java.rmi.server.RemoteServer
          java.rmi.server.UnicastRemoteObject
              org.xmlBlaster.protocol.rmi.XmlBlasterImpl

All Implemented Interfaces:

java.io.Serializable, java.rmi.Remote, I_XmlBlaster

public class XmlBlasterImpl
extends java.rmi.server.UnicastRemoteObject
implements I_XmlBlaster

Implements the xmlBlaster server RMI interface.

See Also:

RequestBroker, Serialized Form

Field Summary

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

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

XmlBlasterImpl(Global glob, AddressServer addressServer, I_XmlBlaster blasterNative)

Method Summary

java.lang.String[]	erase(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Delete messages.
MsgUnitRaw[]	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) Ping to check if xmlBlaster is alive.
java.lang.String	publish(java.lang.String sessionId, MsgUnitRaw msgUnit) Publish a message.
java.lang.String[]	publishArr(java.lang.String sessionId, MsgUnitRaw[] msgUnitArr) Publish messages.
void	publishOneway(java.lang.String sessionId, MsgUnitRaw[] msgUnitArr) Publish messages.
java.lang.String	subscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Subscribe to messages
java.lang.String[]	unSubscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Unsubscribe from messages.

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toString, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

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,
                      AddressServer addressServer,
                      I_XmlBlaster blasterNative)
               throws java.rmi.RemoteException,
                      XmlBlasterException

Throws:

java.rmi.RemoteException

XmlBlasterException

Method Detail

subscribe

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

Subscribe to messages

Specified by:

subscribe in interface I_XmlBlaster

Throws:

java.rmi.RemoteException

XmlBlasterException

See Also:

RequestBroker

unSubscribe

public java.lang.String[] unSubscribe(java.lang.String sessionId,
                                      java.lang.String xmlKey_literal,
                                      java.lang.String qos_literal)
                               throws java.rmi.RemoteException,
                                      XmlBlasterException

Description copied from interface: I_XmlBlaster

Unsubscribe from messages.

Specified by:

unSubscribe in interface I_XmlBlaster

Throws:

java.rmi.RemoteException

XmlBlasterException

See Also:

CORBA xmlBlaster.idl

publish

public java.lang.String publish(java.lang.String sessionId,
                                MsgUnitRaw msgUnit)
                         throws java.rmi.RemoteException,
                                XmlBlasterException

Description copied from interface: I_XmlBlaster

Publish a message.

Specified by:

publish in interface I_XmlBlaster

Throws:

java.rmi.RemoteException

XmlBlasterException

See Also:

CORBA xmlBlaster.idl

publishArr

public java.lang.String[] publishArr(java.lang.String sessionId,
                                     MsgUnitRaw[] msgUnitArr)
                              throws java.rmi.RemoteException,
                                     XmlBlasterException

Description copied from interface: I_XmlBlaster

Publish messages.

Specified by:

publishArr in interface I_XmlBlaster

Throws:

java.rmi.RemoteException

XmlBlasterException

See Also:

CORBA xmlBlaster.idl

publishOneway

public void publishOneway(java.lang.String sessionId,
                          MsgUnitRaw[] msgUnitArr)
                   throws java.rmi.RemoteException

Description copied from interface: I_XmlBlaster

Publish messages.

Specified by:

publishOneway in interface I_XmlBlaster

Throws:

java.rmi.RemoteException

See Also:

CORBA xmlBlaster.idl

erase

public java.lang.String[] erase(java.lang.String sessionId,
                                java.lang.String xmlKey_literal,
                                java.lang.String qos_literal)
                         throws java.rmi.RemoteException,
                                XmlBlasterException

Description copied from interface: I_XmlBlaster

Delete messages.

Specified by:

erase in interface I_XmlBlaster

Throws:

java.rmi.RemoteException

XmlBlasterException

See Also:

CORBA xmlBlaster.idl

get

public MsgUnitRaw[] get(java.lang.String sessionId,
                        java.lang.String xmlKey_literal,
                        java.lang.String qos_literal)
                 throws java.rmi.RemoteException,
                        XmlBlasterException

Synchronous access

Specified by:

get in interface I_XmlBlaster

Returns:

content

Throws:

java.rmi.RemoteException

XmlBlasterException

See Also:

CORBA xmlBlaster.idl

ping

public java.lang.String ping(java.lang.String qos)
                      throws java.rmi.RemoteException

Ping to check if xmlBlaster is alive.

Specified by:

ping in interface I_XmlBlaster

Returns:

Currently an empty string ""

Throws:

java.rmi.RemoteException

See Also:

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