org.apache.cxf.wsn

Class AbstractNotificationBroker

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, endpointEpr, manager, name

Constructor Summary

Constructors

Constructor and Description
AbstractNotificationBroker(String name)

Method Summary

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)

subscribe

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