de.fzj.unicore.wsrflite.xmlbeans.client
Class Consumer

java.lang.Object
  de.fzj.unicore.wsrflite.xmlbeans.client.Consumer

All Implemented Interfaces:

NotificationConsumer, WSNConstants

public class Consumer
extends Object
implements NotificationConsumer

a simple consumer to use on the "client side"
(It stores consumer references statically, so you cannot use it on the services side)

Author:

schuller

Field Summary

protected static org.apache.log4j.Logger

logger

Fields inherited from interface de.fzj.unicore.wsrflite.xmlbeans.wsn.NotificationConsumer

NOTIFY_ACTION

Fields inherited from interface de.fzj.unicore.wsrflite.xmlbeans.wsn.WSNConstants

BW_BASENS, RPFixedTopicSet, RPTopicExpression, RPTopicExpressionDialect, RPTopicSet, SIMPLE_TOPIC, WSN_CHANNEL, XPATH_URI

Constructor Summary

Consumer()

Method Summary

static void	addObserver(Observer observer, QName event) add a local observer for the given event
protected void	doNotifyObservers(QName event, org.oasisOpen.docs.wsn.b2.NotificationMessageHolderType msg)
protected QName	extractEvent(org.oasisOpen.docs.wsn.b2.TopicExpressionType t)
protected void	handleMessage(org.oasisOpen.docs.wsn.b2.NotificationMessageHolderType message) handle a single message: extract event type (qname) and notify observers
void	Notify(org.oasisOpen.docs.wsn.b2.NotifyDocument req) Web service callback method

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.apache.log4j.Logger logger

Constructor Detail

Consumer

public Consumer()

Method Detail

Notify

public void Notify(org.oasisOpen.docs.wsn.b2.NotifyDocument req)
            throws BaseFault

Web service callback method

Specified by:

Notify in interface NotificationConsumer

Throws:

BaseFault

handleMessage

protected void handleMessage(org.oasisOpen.docs.wsn.b2.NotificationMessageHolderType message)

handle a single message: extract event type (qname) and notify observers

Parameters:

message -

extractEvent

protected QName extractEvent(org.oasisOpen.docs.wsn.b2.TopicExpressionType t)

doNotifyObservers

protected void doNotifyObservers(QName event,
                                 org.oasisOpen.docs.wsn.b2.NotificationMessageHolderType msg)

addObserver

public static void addObserver(Observer observer,
                               QName event)

add a local observer for the given event