xmlBlaster 2.1.0 API

org.xmlBlaster.client
Interface I_StreamingCallback

All Known Implementing Classes:
MsgInterceptor, TestStreamMessages

public interface I_StreamingCallback

Interface to receive asynchronously send callback messages from xmlBlaster.

Please implement this to receive your messages.

Version:
$Revision: 1.13 $
Author:
Michele Laghi.

Method Summary
 java.lang.String update(java.lang.String cbSessionId, UpdateKey updateKey, java.io.InputStream contentStream, UpdateQos updateQos)
          This is the callback method invoked from I_XmlBlasterAccess informing the client in an asynchronous mode about a new message.
 

Method Detail

update

java.lang.String update(java.lang.String cbSessionId,
                        UpdateKey updateKey,
                        java.io.InputStream contentStream,
                        UpdateQos updateQos)
                        throws XmlBlasterException,
                               java.io.IOException
This is the callback method invoked from I_XmlBlasterAccess informing the client in an asynchronous mode about a new message.

So you should implement in your client code the I_Callback interface - suppling the update() method where you can do with the message whatever you want.

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 to be accessed as an InputStream.
qos - Quality of Service of the MsgUnit
Throws:
XmlBlasterException
java.io.IOException
See Also:
I_XmlBlasterAccess

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.