public abstract class JmsPublisher extends AbstractPublisher implements org.apache.activemq.advisory.ConsumerListener
demand, publisherReference, topicaddress, endpoint, manager, name| Constructor and Description |
|---|
JmsPublisher(String name) |
| Modifier and Type | Method and Description |
|---|---|
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) |
create, destroyRegistration, getPublisherReferencegetAddress, getEpr, getManager, getMBeanName, getName, getWSDLLocation, register, setAddress, setManager, unregisterpublic JmsPublisher(String name)
public javax.jms.Connection getConnection()
public void setConnection(javax.jms.Connection connection)
public void notify(NotificationMessageHolderType messageHolder)
notify in class AbstractPublisherprotected void validatePublisher(RegisterPublisher registerPublisherRequest) throws InvalidTopicExpressionFault, PublisherRegistrationFailedFault, PublisherRegistrationRejectedFault, ResourceUnknownFault, TopicNotSupportedFault
protected void start()
throws PublisherRegistrationFailedFault
start in class AbstractPublisherPublisherRegistrationFailedFaultprotected void destroy()
throws ResourceNotDestroyedFault
destroy in class AbstractPublisherResourceNotDestroyedFaultpublic void onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent event)
onConsumerEvent in interface org.apache.activemq.advisory.ConsumerListenerprotected abstract Object startSubscription(TopicExpressionType topic)
protected abstract void stopSubscription(Object sub)
Apache CXF