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
Class AbstractNotificationBroker

java.lang.Object
  extended by org.apache.cxf.wsn.AbstractEndpoint
      extended by 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
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
AbstractNotificationBroker(String name)
           
 
Method Summary
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, 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
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