org.xmlBlaster.client.jmx
Class XmlBlasterInvocationHandler

java.lang.Object
  org.xmlBlaster.client.jmx.XmlBlasterInvocationHandler

All Implemented Interfaces:

java.lang.reflect.InvocationHandler, I_Callback

public class XmlBlasterInvocationHandler
extends java.lang.Object
implements I_Callback, java.lang.reflect.InvocationHandler

Field Summary

private java.util.Map	callbackBuffer
private Global	global
private static java.util.logging.Logger	log
private java.lang.String	ME
(package private) static long	messageID
private static int	port
(package private) static SerializeHelper	ser
private SubscribeKey	subsKey
private I_XmlBlasterAccess	xmlBlasterAccess

Constructor Summary

XmlBlasterInvocationHandler(java.lang.String serverName, Global global)

Method Summary

private void	close()
java.lang.Object	invoke(java.lang.Object proxy, java.lang.reflect.Method method, java.lang.Object[] args) Method Invoke is called by the client, The MethodName is extracted and wrapped into an MethodInvocation Object
java.lang.String	update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) Update invoked, when Message on subscribed Topic is received.

Methods inherited from class java.lang.Object

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

Field Detail

ser

static SerializeHelper ser

messageID

static long messageID

subsKey

private SubscribeKey subsKey

global

private final Global global

log

private static java.util.logging.Logger log

xmlBlasterAccess

private I_XmlBlasterAccess xmlBlasterAccess

ME

private java.lang.String ME

port

private static int port

callbackBuffer

private java.util.Map callbackBuffer

Constructor Detail

XmlBlasterInvocationHandler

public XmlBlasterInvocationHandler(java.lang.String serverName,
                                   Global global)

Method Detail

invoke

public java.lang.Object invoke(java.lang.Object proxy,
                               java.lang.reflect.Method method,
                               java.lang.Object[] args)
                        throws java.lang.Throwable

Method Invoke is called by the client, The MethodName is extracted and wrapped into an MethodInvocation Object

The MethodInvocation is published to the the server.
The Mapping for the return values after the invocation is done via a callbackbuffer

Specified by:

invoke in interface java.lang.reflect.InvocationHandler

Throws:

java.lang.Throwable

close

private void close()

update

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

Update invoked, when Message on subscribed Topic is received. Most probably it is the returning Object from a recent MethodInvocation

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