Apache CXF API

org.apache.cxf.wsn.client
Class Publisher

java.lang.Object
  extended by 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
static interface Publisher.Callback
           
protected  class Publisher.PublisherSubscription
           
 
Field Summary
static QName QNAME_TOPIC_EXPRESSION
           
static String WSN_URI
           
 
Constructor Summary
Publisher(Publisher.Callback callback, String address)
           
 
Method Summary
 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

Apache CXF API

Apache CXF