org.xmlBlaster.util.admin.extern
Class XmlBlasterConnector

java.lang.Object
  org.xmlBlaster.util.admin.extern.XmlBlasterConnector

All Implemented Interfaces:

I_Callback, XmlBlasterConnectorMBean

public class XmlBlasterConnector

extends java.lang.Object

implements XmlBlasterConnectorMBean, I_Callback

XmlBlasterConnector is a tiny embedded xmlBlaster server instance. It is both publisher and subscriber to a topic. XmlBlasterConnector extracts MethodInvocation Object from the Message Unit and handles the invocation, stores the return value

Field Summary

static int	FINISHED
boolean	jmxInterfaceAlive
static int	SENDING
static int	UNKNOWN

Constructor Summary

XmlBlasterConnector()

Method Summary

boolean	isConnectorAlive() Display internal status to Management
void	start(java.lang.String agentID) Starts the connector - starts an embedded xmlBlaster that listens on port 3424 Subscribes to topic where MethodInvocations are placed Starts another (new!) MBeanServer
void	startEmbeddedXmlBlasterServer() Start EmbeddedXmlBlaster
void	startInternal(javax.management.MBeanServer server) Starts the connector - starts an embedded xmlBlaster that listens on port 3424 Subscribes to topic where MethodInvocations are placed Uses MBeanServer from JMXWrapper
void	stop(java.lang.String agentId) Stop Service
java.lang.String	update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) update() is invoked, when a methodInvocation for the given key arrives MethodInvocation is deserialized, the method is invoked and the return value is stored (within the MethodInvocation Object)

Methods inherited from class java.lang.Object

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

Field Detail

UNKNOWN

public static int UNKNOWN

SENDING

public static int SENDING

FINISHED

public static int FINISHED

jmxInterfaceAlive

public boolean jmxInterfaceAlive

Constructor Detail

XmlBlasterConnector

public XmlBlasterConnector()

Method Detail

start

public void start(java.lang.String agentID)

Starts the connector - starts an embedded xmlBlaster that listens on port 3424 Subscribes to topic where MethodInvocations are placed Starts another (new!) MBeanServer

Specified by:

start in interface XmlBlasterConnectorMBean

startInternal

public void startInternal(javax.management.MBeanServer server)

Starts the connector - starts an embedded xmlBlaster that listens on port 3424 Subscribes to topic where MethodInvocations are placed Uses MBeanServer from JMXWrapper

Specified by:

startInternal in interface XmlBlasterConnectorMBean

startEmbeddedXmlBlasterServer

public void startEmbeddedXmlBlasterServer()

Start EmbeddedXmlBlaster

update

public java.lang.String update(java.lang.String cbSessionId,
                               UpdateKey updateKey,
                               byte[] content,
                               UpdateQos updateQos)

update() is invoked, when a methodInvocation for the given key arrives MethodInvocation is deserialized, the method is invoked and the return value is stored (within the MethodInvocation Object)

Specified by:

update in interface I_Callback

Parameters:

cbSessionId - The session ID specified by the client which registered the callback. You can specify a cbSessionId during connection (with ConnectQos) and this is bounced back here so you can authenticate the message.

updateKey - The arrived key containing the topic name

content - The arrived message content. This is your payload.

See Also:

I_XmlBlasterAccess

isConnectorAlive

public boolean isConnectorAlive()

Display internal status to Management

Specified by:

isConnectorAlive in interface XmlBlasterConnectorMBean

stop

public void stop(java.lang.String agentId)

Stop Service

Specified by:

stop in interface XmlBlasterConnectorMBean