xmlBlaster 2.2.0 API

javaclients
Class ClientSub

java.lang.Object
  extended by 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)

xmlBlaster 2.2.0 API

Copyright © 1999-2014 The xmlBlaster.org contributers.