org.apache.cxf.wsn.jms
Class JmsPublisher
java.lang.Object
org.apache.cxf.wsn.AbstractEndpoint
org.apache.cxf.wsn.AbstractPublisher
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsPublisher
public JmsPublisher(String name)
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