Apache CXF API

org.apache.cxf.wsn.jms
Class JmsPublisher

java.lang.Object
  extended by org.apache.cxf.wsn.AbstractEndpoint
      extended by org.apache.cxf.wsn.AbstractPublisher
          extended by org.apache.cxf.wsn.jms.JmsPublisher
All Implemented Interfaces:
org.apache.activemq.advisory.ConsumerListener, EndpointMBean, PublisherRegistrationManager
Direct Known Subclasses:
JaxwsPublisher

public abstract class JmsPublisher
extends AbstractPublisher
implements org.apache.activemq.advisory.ConsumerListener


Field Summary
 
Fields inherited from class org.apache.cxf.wsn.AbstractPublisher
demand, publisherReference, topic
 
Fields inherited from class org.apache.cxf.wsn.AbstractEndpoint
address, endpoint, manager, name
 
Constructor Summary
JmsPublisher(String name)
           
 
Method Summary
protected  void destroy()
           
 javax.jms.Connection getConnection()
           
 void notify(NotificationMessageHolderType messageHolder)
           
 void onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent event)
           
 void setConnection(javax.jms.Connection connection)
           
protected  void start()
           
protected abstract  Object startSubscription(TopicExpressionType topic)
           
protected abstract  void stopSubscription(Object sub)
           
protected  void validatePublisher(RegisterPublisher registerPublisherRequest)
           
 
Methods inherited from class org.apache.cxf.wsn.AbstractPublisher
create, destroyRegistration, getPublisherReference
 
Methods inherited from class org.apache.cxf.wsn.AbstractEndpoint
getAddress, getEpr, getManager, getMBeanName, getName, register, setAddress, setManager, unregister
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JmsPublisher

public JmsPublisher(String name)
Method Detail

getConnection

public javax.jms.Connection getConnection()

setConnection

public void setConnection(javax.jms.Connection connection)

notify

public void notify(NotificationMessageHolderType messageHolder)
Specified by:
notify in class AbstractPublisher

validatePublisher

protected void validatePublisher(RegisterPublisher registerPublisherRequest)
                          throws InvalidTopicExpressionFault,
                                 PublisherRegistrationFailedFault,
                                 PublisherRegistrationRejectedFault,
                                 ResourceUnknownFault,
                                 TopicNotSupportedFault
Overrides:
validatePublisher in class AbstractPublisher
Throws:
InvalidTopicExpressionFault
PublisherRegistrationFailedFault
PublisherRegistrationRejectedFault
ResourceUnknownFault
TopicNotSupportedFault

start

protected void start()
              throws PublisherRegistrationFailedFault
Specified by:
start in class AbstractPublisher
Throws:
PublisherRegistrationFailedFault

destroy

protected void destroy()
                throws ResourceNotDestroyedFault
Overrides:
destroy in class AbstractPublisher
Throws:
ResourceNotDestroyedFault

onConsumerEvent

public void onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent event)
Specified by:
onConsumerEvent in interface org.apache.activemq.advisory.ConsumerListener

startSubscription

protected abstract Object startSubscription(TopicExpressionType topic)

stopSubscription

protected abstract void stopSubscription(Object sub)

Apache CXF API

Apache CXF