AbstractNotificationBroker (Apache CXF JavaDoc 3.1.0 API)

java.lang.Object
- org.apache.cxf.wsn.AbstractEndpoint
- - org.apache.cxf.wsn.AbstractNotificationBroker

All Implemented Interfaces:: EndpointMBean, NotificationBrokerMBean, NotificationBroker, GetResourceProperty

Direct Known Subclasses:: JmsNotificationBroker

public abstract class AbstractNotificationBroker
extends AbstractEndpoint
implements NotificationBroker, NotificationBrokerMBean, GetResourceProperty

Field Summary

Fields
Modifier and Type	Field and Description
`static QName`	`FIXED_TOPIC_SET_QNAME`
`static String`	`NAMESPACE_URI`
`static String`	`PREFIX`
`static QName`	`TOPIC_EXPRESSION_DIALECT_QNAME`
`static QName`	`TOPIC_EXPRESSION_QNAME`
`static QName`	`TOPIC_SET_QNAME`

Fields inherited from class org.apache.cxf.wsn.AbstractEndpoint
address, endpoint, manager, name

Constructor Summary

Constructors
Constructor and Description

AbstractNotificationBroker(String name)

Constructors
Constructor and Description
`AbstractNotificationBroker(String name)`

Method Summary

Methods
Modifier and Type	Method and Description
`protected abstract AbstractPublisher`	`createPublisher(String name)`
`protected abstract AbstractSubscription`	`createSubscription(String name)`
`void`	`destroy()`
`EndpointMBean`	`getAnonymousPublisher()`
`GetCurrentMessageResponse`	`getCurrentMessage(GetCurrentMessage getCurrentMessageRequest)`
`ObjectName`	`getMBeanName()`
`List<String>`	`getPublisher()`
`EndpointMBean`	`getPublisher(String name)`
`protected AbstractPublisher`	`getPublisher(W3CEndpointReference producerReference)`
`GetResourcePropertyResponse`	`getResourceProperty(QName getResourcePropertyRequest)`
`EndpointMBean`	`getSubscription(String name)`
`List<String>`	`getSubscriptions()`
`protected GetResourcePropertyResponse`	`handleGetResourceProperty(QName property)`
`protected void`	`handleNotify(Notify notify)`
`RegisterPublisherResponse`	`handleRegisterPublisher(RegisterPublisher registerPublisherRequest)`
`SubscribeResponse`	`handleSubscribe(Subscribe subscribeRequest, EndpointManager manager)`
`void`	`init()`
`void`	`notify(Notify notify)`
`RegisterPublisherResponse`	`registerPublisher(RegisterPublisher registerPublisherRequest)`
`SubscribeResponse`	`subscribe(Subscribe subscribeRequest)`
`void`	`unsubscribe(String address)`

Methods inherited from class org.apache.cxf.wsn.AbstractEndpoint
getAddress, getEpr, getManager, getName, getWSDLLocation, register, setAddress, setManager, unregister

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cxf.wsn.EndpointMBean
getAddress, getName, register, unregister

Field Detail

NAMESPACE_URI

public static final String NAMESPACE_URI

See Also:: Constant Field Values

PREFIX
```
public static final String PREFIX
```
See Also:
Constant Field Values

TOPIC_EXPRESSION_QNAME

public static final QName TOPIC_EXPRESSION_QNAME

FIXED_TOPIC_SET_QNAME

public static final QName FIXED_TOPIC_SET_QNAME

TOPIC_EXPRESSION_DIALECT_QNAME

public static final QName TOPIC_EXPRESSION_DIALECT_QNAME

TOPIC_SET_QNAME

public static final QName TOPIC_SET_QNAME

Constructor Detail

AbstractNotificationBroker

public AbstractNotificationBroker(String name)

Method Detail

getMBeanName
```
public ObjectName getMBeanName()
```
Overrides:

getMBeanName in class AbstractEndpoint

init

public void init()
          throws Exception

Throws:: Exception

destroy

public void destroy()
             throws Exception

Throws:: Exception

getPublisher
```
public List<String> getPublisher()
```
Specified by:

getPublisher in interface NotificationBrokerMBean

getSubscriptions
```
public List<String> getSubscriptions()
```
Specified by:

getSubscriptions in interface NotificationBrokerMBean

getPublisher
```
public EndpointMBean getPublisher(String name)
```
Specified by:

getPublisher in interface NotificationBrokerMBean

getSubscription
```
public EndpointMBean getSubscription(String name)
```
Specified by:

getSubscription in interface NotificationBrokerMBean

getAnonymousPublisher
```
public EndpointMBean getAnonymousPublisher()
```
Specified by:

getAnonymousPublisher in interface NotificationBrokerMBean

notify
```
public void notify(Notify notify)
```
Specified by:

notify in interface NotificationBroker

Parameters:
notify -

handleNotify

protected void handleNotify(Notify notify)

getPublisher

protected AbstractPublisher getPublisher(W3CEndpointReference producerReference)

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

Specified by:: subscribe in interface NotificationBroker
Parameters:: subscribeRequest -
Returns:: returns org.oasis_open.docs.wsn.b_1.SubscribeResponse
Throws:: SubscribeCreationFailedFault; InvalidTopicExpressionFault; TopicNotSupportedFault; InvalidFilterFault; InvalidProducerPropertiesExpressionFault; ResourceUnknownFault; InvalidMessageContentExpressionFault; TopicExpressionDialectUnknownFault; UnacceptableInitialTerminationTimeFault; UnsupportedPolicyRequestFault; UnrecognizedPolicyRequestFault

handleSubscribe

public SubscribeResponse handleSubscribe(Subscribe subscribeRequest,
                                EndpointManager manager)
                                  throws InvalidFilterFault,
                                         InvalidMessageContentExpressionFault,
                                         InvalidProducerPropertiesExpressionFault,
                                         InvalidTopicExpressionFault,
                                         SubscribeCreationFailedFault,
                                         TopicExpressionDialectUnknownFault,
                                         TopicNotSupportedFault,
                                         UnacceptableInitialTerminationTimeFault,
                                         UnsupportedPolicyRequestFault,
                                         UnrecognizedPolicyRequestFault

Throws:: InvalidFilterFault; InvalidMessageContentExpressionFault; InvalidProducerPropertiesExpressionFault; InvalidTopicExpressionFault; SubscribeCreationFailedFault; TopicExpressionDialectUnknownFault; TopicNotSupportedFault; UnacceptableInitialTerminationTimeFault; UnsupportedPolicyRequestFault; UnrecognizedPolicyRequestFault

unsubscribe

public void unsubscribe(String address)
                 throws UnableToDestroySubscriptionFault

Throws:: UnableToDestroySubscriptionFault

getCurrentMessage

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

Specified by:: getCurrentMessage in interface NotificationBroker
Parameters:: getCurrentMessageRequest -
Returns:: returns org.oasis_open.docs.wsn.b_1.GetCurrentMessageResponse
Throws:: MultipleTopicsSpecifiedFault; TopicNotSupportedFault; InvalidTopicExpressionFault; ResourceUnknownFault; TopicExpressionDialectUnknownFault; NoCurrentMessageOnTopicFault

registerPublisher

public RegisterPublisherResponse registerPublisher(RegisterPublisher registerPublisherRequest)
                                            throws InvalidTopicExpressionFault,
                                                   PublisherRegistrationFailedFault,
                                                   PublisherRegistrationRejectedFault,
                                                   ResourceUnknownFault,
                                                   TopicNotSupportedFault

Specified by:: registerPublisher in interface NotificationBroker
Parameters:: registerPublisherRequest -
Returns:: returns org.oasis_open.docs.wsn.br_1.RegisterPublisherResponse
Throws:: PublisherRegistrationRejectedFault; InvalidTopicExpressionFault; TopicNotSupportedFault; ResourceUnknownFault; PublisherRegistrationFailedFault

handleRegisterPublisher

public RegisterPublisherResponse handleRegisterPublisher(RegisterPublisher registerPublisherRequest)
                                                  throws InvalidTopicExpressionFault,
                                                         PublisherRegistrationFailedFault,
                                                         PublisherRegistrationRejectedFault,
                                                         ResourceUnknownFault,
                                                         TopicNotSupportedFault

Throws:: InvalidTopicExpressionFault; PublisherRegistrationFailedFault; PublisherRegistrationRejectedFault; ResourceUnknownFault; TopicNotSupportedFault

createPublisher

protected abstract AbstractPublisher createPublisher(String name)

createSubscription

protected abstract AbstractSubscription createSubscription(String name)

getResourceProperty

public GetResourcePropertyResponse getResourceProperty(QName getResourcePropertyRequest)
                                                throws ResourceUnavailableFault,
                                                       ResourceUnknownFault,
                                                       InvalidResourcePropertyQNameFault

Specified by:: getResourceProperty in interface GetResourceProperty
Throws:: ResourceUnavailableFault; ResourceUnknownFault; InvalidResourcePropertyQNameFault

handleGetResourceProperty

protected GetResourcePropertyResponse handleGetResourceProperty(QName property)
                                                         throws ResourceUnavailableFault,
                                                                ResourceUnknownFault,
                                                                InvalidResourcePropertyQNameFault

Throws:: ResourceUnavailableFault; ResourceUnknownFault; InvalidResourcePropertyQNameFault

Class AbstractNotificationBroker

Field Summary

Fields inherited from class org.apache.cxf.wsn.AbstractEndpoint

Constructor Summary

Method Summary

Methods inherited from class org.apache.cxf.wsn.AbstractEndpoint

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.cxf.wsn.EndpointMBean

Field Detail

NAMESPACE_URI

PREFIX

TOPIC_EXPRESSION_QNAME

FIXED_TOPIC_SET_QNAME

TOPIC_EXPRESSION_DIALECT_QNAME

TOPIC_SET_QNAME

Constructor Detail

AbstractNotificationBroker

Method Detail

getMBeanName

init

destroy

getPublisher

getSubscriptions

getPublisher

getSubscription

getAnonymousPublisher

notify

handleNotify

getPublisher

subscribe

handleSubscribe

unsubscribe

getCurrentMessage

registerPublisher

handleRegisterPublisher

createPublisher

createSubscription

getResourceProperty

handleGetResourceProperty