org.apache.cxf.wsn.client

Class Publisher

java.lang.Object

org.apache.cxf.wsn.client.Publisher

All Implemented Interfaces:

Referencable, NotificationProducer

public class Publisher
extends Object
implements NotificationProducer, Referencable

Demand-based publisher.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Publisher.Callback
protected class	Publisher.PublisherSubscription

Field Summary

Fields

Modifier and Type	Field and Description
static QName	QNAME_TOPIC_EXPRESSION
static String	WSN_URI

Constructor Summary

Constructors

Constructor and Description
Publisher(Publisher.Callback callback, String address)

Method Summary

Modifier and Type	Method and Description
GetCurrentMessageResponse	getCurrentMessage(GetCurrentMessage getCurrentMessageRequest)
W3CEndpointReference	getEpr()
void	stop()
SubscribeResponse	subscribe(Subscribe subscribeRequest)
protected void	unsubscribe(TopicExpressionType topic)

Methods inherited from class java.lang.Object

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

Field Detail

WSN_URI

public static final String WSN_URI

See Also:

Constant Field Values

QNAME_TOPIC_EXPRESSION

public static final QName QNAME_TOPIC_EXPRESSION

Constructor Detail

Publisher

public Publisher(Publisher.Callback callback,
                 String address)

Method Detail

stop

public void stop()

getEpr

public W3CEndpointReference getEpr()

Specified by:

getEpr in interface Referencable

subscribe

public SubscribeResponse subscribe(Subscribe subscribeRequest)
                            throws InvalidTopicExpressionFault,
                                   ResourceUnknownFault,
                                   InvalidProducerPropertiesExpressionFault,
                                   UnrecognizedPolicyRequestFault,
                                   TopicExpressionDialectUnknownFault,
                                   NotifyMessageNotSupportedFault,
                                   InvalidFilterFault,
                                   UnsupportedPolicyRequestFault,
                                   InvalidMessageContentExpressionFault,
                                   SubscribeCreationFailedFault,
                                   TopicNotSupportedFault,
                                   UnacceptableInitialTerminationTimeFault

Specified by:

subscribe in interface NotificationProducer

Throws:

InvalidTopicExpressionFault

ResourceUnknownFault

InvalidProducerPropertiesExpressionFault

UnrecognizedPolicyRequestFault

TopicExpressionDialectUnknownFault

NotifyMessageNotSupportedFault

InvalidFilterFault

UnsupportedPolicyRequestFault

InvalidMessageContentExpressionFault

SubscribeCreationFailedFault

TopicNotSupportedFault

UnacceptableInitialTerminationTimeFault

unsubscribe

protected void unsubscribe(TopicExpressionType topic)

getCurrentMessage

public GetCurrentMessageResponse getCurrentMessage(GetCurrentMessage getCurrentMessageRequest)
                                            throws InvalidTopicExpressionFault,
                                                   ResourceUnknownFault,
                                                   TopicExpressionDialectUnknownFault,
                                                   MultipleTopicsSpecifiedFault,
                                                   NoCurrentMessageOnTopicFault,
                                                   TopicNotSupportedFault

Specified by:

getCurrentMessage in interface NotificationProducer

Throws:

InvalidTopicExpressionFault

ResourceUnknownFault

TopicExpressionDialectUnknownFault

MultipleTopicsSpecifiedFault

NoCurrentMessageOnTopicFault

TopicNotSupportedFault