NotificationBroker (Apache CXF JavaDoc 3.1.0 API)

java.lang.Object
- org.apache.cxf.wsn.client.NotificationBroker

All Implemented Interfaces:: Referencable

public class NotificationBroker
extends Object
implements Referencable

Field Summary

Fields
Modifier and Type Field and Description

static QName QNAME_MESSAGE_CONTENT

static QName QNAME_TOPIC_EXPRESSION

static String WSN_URI

static String XPATH1_URI

Fields
Modifier and Type	Field and Description
`static QName`	`QNAME_MESSAGE_CONTENT`
`static QName`	`QNAME_TOPIC_EXPRESSION`
`static String`	`WSN_URI`
`static String`	`XPATH1_URI`

Constructor Summary

Constructors
Constructor and Description
`NotificationBroker(String address, Class<?>... cls)`
`NotificationBroker(W3CEndpointReference epr, Class<?>... cls)`

Method Summary

Methods
Modifier and Type	Method and Description
`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)

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

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

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

Class NotificationBroker

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

WSN_URI

XPATH1_URI

QNAME_TOPIC_EXPRESSION

QNAME_MESSAGE_CONTENT

Constructor Detail

NotificationBroker

NotificationBroker

Method Detail

setExtraClasses

getBroker

getEpr

notify

notify

subscribe

subscribe

subscribe

getCurrentMessage

registerPublisher

registerPublisher

registerPublisher