javaclients
Class ClientSub

java.lang.Object
  javaclients.ClientSub

All Implemented Interfaces:

I_Callback

public class ClientSub
extends java.lang.Object
implements I_Callback

This client tests the method subscribe() with a later publish() with XPath query.
The subscribe() should be recognized for this later arriving publish().

This demo uses the I_XmlBlasterAccess helper class, which hides the raw CORBA/RMI/XMLRPC nastiness.
I_XmlBlasterAccesss hides how to find the xmlBlaster server (see I_XmlBlasterAccess API).
I_XmlBlasterAccess installs a callback server (for CORBA,RMI or XMLRPC) for you and informs you about asynchronous callbacks using the I_Callback interface (method update() see below).

If you want to know step by step what happens with CORBA, study the corba/ClientRaw.java example. Here we use all available Java helper classes.

Invoke examples:

    java -cp ../../lib/xmlBlaster.jar javaclients.ClientSub

    java javaclients.ClientSub -session.name Jeff -dispatch/connection/protocol RMI

    java javaclients.ClientSub -help
 

Field Summary

static long	elapsed
private Global	glob
private static java.util.logging.Logger	log
private static java.lang.String	ME
private int	numReceived
static long	startTime

Constructor Summary

ClientSub(Global glob)

Method Summary

static void	main(java.lang.String[] args)
private void	sendSomeMessages(I_XmlBlasterAccess blasterConnection)
java.lang.String	update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) This is the callback method invoked from xmlBlaster delivering us a new asynchronous message.

Methods inherited from class java.lang.Object

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

Field Detail

ME

private static java.lang.String ME

glob

private final Global glob

log

private static java.util.logging.Logger log

numReceived

private int numReceived

startTime

public static long startTime

elapsed

public static long elapsed

Constructor Detail

ClientSub

public ClientSub(Global glob)

Method Detail

sendSomeMessages

private void sendSomeMessages(I_XmlBlasterAccess blasterConnection)

update

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

This is the callback method invoked from xmlBlaster delivering us a new asynchronous message.

Specified by:

update in interface I_Callback

Parameters:

cbSessionId - The session ID specified by the client which registered the callback

updateKey - The arrived key

content - The arrived message content

qos - Quality of Service of the MsgUnit

See Also:

I_Callback.update(String, UpdateKey, byte[], UpdateQos)

main

public static void main(java.lang.String[] args)