Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.apache.cxf.wsn.client
Class NotificationBroker

java.lang.Object
  extended by org.apache.cxf.wsn.client.NotificationBroker
All Implemented Interfaces:
Referencable
public class NotificationBroker
extends Object
implements Referencable

Field Summary
static QName QNAME_MESSAGE_CONTENT
           
static QName QNAME_TOPIC_EXPRESSION
           
static String WSN_URI
           
static String XPATH1_URI
           
 
Constructor Summary
NotificationBroker(String address, Class<?>... cls)
           
NotificationBroker(W3CEndpointReference epr, Class<?>... cls)
           
 
Method Summary
 NotificationBroker getBroker()
           
 List<Object> getCurrentMessage(String topic)
           
 W3CEndpointReference getEpr()
           
 void notify(Referencable publisher, String topic, Object msg)
           
 void notify(String topic, Object msg)
           
 Registration registerPublisher(Referencable publisher, List<String> topics, boolean demand)
           
 Registration registerPublisher(Referencable publisher, String topic)
           
 Registration registerPublisher(Referencable publisher, String topic, boolean demand)
           
 void setExtraClasses(Class<?>... c)
           
 Subscription subscribe(Referencable consumer, String topic)
           
 Subscription subscribe(Referencable consumer, String topic, String xpath)
           
 Subscription subscribe(Referencable consumer, String topic, String xpath, boolean raw)
           
 
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

XPATH1_URI

public static final String XPATH1_URI
See Also:
Constant Field Values

QNAME_TOPIC_EXPRESSION

public static final QName QNAME_TOPIC_EXPRESSION

QNAME_MESSAGE_CONTENT

public static final QName QNAME_MESSAGE_CONTENT
Constructor Detail

NotificationBroker

public NotificationBroker(String address,
                          Class<?>... cls)

NotificationBroker

public NotificationBroker(W3CEndpointReference epr,
                          Class<?>... cls)
Method Detail

setExtraClasses

public void setExtraClasses(Class<?>... c)

getBroker

public NotificationBroker getBroker()

getEpr

public W3CEndpointReference getEpr()
Specified by:
getEpr in interface Referencable

notify

public void notify(String topic,
                   Object msg)

notify

public void notify(Referencable publisher,
                   String topic,
                   Object msg)

subscribe

public Subscription subscribe(Referencable consumer,
                              String topic)
                       throws TopicExpressionDialectUnknownFault,
                              InvalidFilterFault,
                              TopicNotSupportedFault,
                              UnacceptableInitialTerminationTimeFault,
                              SubscribeCreationFailedFault,
                              InvalidMessageContentExpressionFault,
                              InvalidTopicExpressionFault,
                              ResourceUnknownFault,
                              UnsupportedPolicyRequestFault,
                              UnrecognizedPolicyRequestFault,
                              NotifyMessageNotSupportedFault,
                              InvalidProducerPropertiesExpressionFault
Throws:
TopicExpressionDialectUnknownFault
InvalidFilterFault
TopicNotSupportedFault
UnacceptableInitialTerminationTimeFault
SubscribeCreationFailedFault
InvalidMessageContentExpressionFault
InvalidTopicExpressionFault
ResourceUnknownFault
UnsupportedPolicyRequestFault
UnrecognizedPolicyRequestFault
NotifyMessageNotSupportedFault
InvalidProducerPropertiesExpressionFault

subscribe

public Subscription subscribe(Referencable consumer,
                              String topic,
                              String xpath)
                       throws TopicExpressionDialectUnknownFault,
                              InvalidFilterFault,
                              TopicNotSupportedFault,
                              UnacceptableInitialTerminationTimeFault,
                              SubscribeCreationFailedFault,
                              InvalidMessageContentExpressionFault,
                              InvalidTopicExpressionFault,
                              ResourceUnknownFault,
                              UnsupportedPolicyRequestFault,
                              UnrecognizedPolicyRequestFault,
                              NotifyMessageNotSupportedFault,
                              InvalidProducerPropertiesExpressionFault
Throws:
TopicExpressionDialectUnknownFault
InvalidFilterFault
TopicNotSupportedFault
UnacceptableInitialTerminationTimeFault
SubscribeCreationFailedFault
InvalidMessageContentExpressionFault
InvalidTopicExpressionFault
ResourceUnknownFault
UnsupportedPolicyRequestFault
UnrecognizedPolicyRequestFault
NotifyMessageNotSupportedFault
InvalidProducerPropertiesExpressionFault

subscribe

public Subscription subscribe(Referencable consumer,
                              String topic,
                              String xpath,
                              boolean raw)
                       throws TopicNotSupportedFault,
                              InvalidFilterFault,
                              TopicExpressionDialectUnknownFault,
                              UnacceptableInitialTerminationTimeFault,
                              SubscribeCreationFailedFault,
                              InvalidMessageContentExpressionFault,
                              InvalidTopicExpressionFault,
                              UnrecognizedPolicyRequestFault,
                              UnsupportedPolicyRequestFault,
                              ResourceUnknownFault,
                              NotifyMessageNotSupportedFault,
                              InvalidProducerPropertiesExpressionFault
Throws:
TopicNotSupportedFault
InvalidFilterFault
TopicExpressionDialectUnknownFault
UnacceptableInitialTerminationTimeFault
SubscribeCreationFailedFault
InvalidMessageContentExpressionFault
InvalidTopicExpressionFault
UnrecognizedPolicyRequestFault
UnsupportedPolicyRequestFault
ResourceUnknownFault
NotifyMessageNotSupportedFault
InvalidProducerPropertiesExpressionFault

getCurrentMessage

public List<Object> getCurrentMessage(String topic)
                               throws TopicNotSupportedFault,
                                      TopicExpressionDialectUnknownFault,
                                      MultipleTopicsSpecifiedFault,
                                      InvalidTopicExpressionFault,
                                      ResourceUnknownFault,
                                      NoCurrentMessageOnTopicFault
Throws:
TopicNotSupportedFault
TopicExpressionDialectUnknownFault
MultipleTopicsSpecifiedFault
InvalidTopicExpressionFault
ResourceUnknownFault
NoCurrentMessageOnTopicFault

registerPublisher

public Registration registerPublisher(Referencable publisher,
                                      String topic)
                               throws TopicNotSupportedFault,
                                      PublisherRegistrationFailedFault,
                                      UnacceptableInitialTerminationTimeFault,
                                      InvalidTopicExpressionFault,
                                      ResourceUnknownFault,
                                      PublisherRegistrationRejectedFault
Throws:
TopicNotSupportedFault
PublisherRegistrationFailedFault
UnacceptableInitialTerminationTimeFault
InvalidTopicExpressionFault
ResourceUnknownFault
PublisherRegistrationRejectedFault

registerPublisher

public Registration registerPublisher(Referencable publisher,
                                      String topic,
                                      boolean demand)
                               throws TopicNotSupportedFault,
                                      PublisherRegistrationFailedFault,
                                      UnacceptableInitialTerminationTimeFault,
                                      InvalidTopicExpressionFault,
                                      ResourceUnknownFault,
                                      PublisherRegistrationRejectedFault
Throws:
TopicNotSupportedFault
PublisherRegistrationFailedFault
UnacceptableInitialTerminationTimeFault
InvalidTopicExpressionFault
ResourceUnknownFault
PublisherRegistrationRejectedFault

registerPublisher

public Registration registerPublisher(Referencable publisher,
                                      List<String> topics,
                                      boolean demand)
                               throws TopicNotSupportedFault,
                                      PublisherRegistrationFailedFault,
                                      UnacceptableInitialTerminationTimeFault,
                                      InvalidTopicExpressionFault,
                                      ResourceUnknownFault,
                                      PublisherRegistrationRejectedFault
Throws:
TopicNotSupportedFault
PublisherRegistrationFailedFault
UnacceptableInitialTerminationTimeFault
InvalidTopicExpressionFault
ResourceUnknownFault
PublisherRegistrationRejectedFault
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Apache CXF