public abstract class JmsNotificationBroker extends AbstractNotificationBroker
FIXED_TOPIC_SET_QNAME, NAMESPACE_URI, PREFIX, TOPIC_EXPRESSION_DIALECT_QNAME, TOPIC_EXPRESSION_QNAME, TOPIC_SET_QNAMEaddress, endpoint, manager, name| Constructor and Description |
|---|
JmsNotificationBroker(String name) |
JmsNotificationBroker(String name,
javax.jms.ConnectionFactory connectionFactory) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract JmsPublisher |
createJmsPublisher(String name) |
protected abstract JmsSubscription |
createJmsSubscription(String name) |
protected AbstractPublisher |
createPublisher(String name) |
protected AbstractSubscription |
createSubscription(String name) |
void |
destroy() |
javax.jms.ConnectionFactory |
getConnectionFactory() |
protected GetResourcePropertyResponse |
handleGetResourceProperty(QName property) |
void |
init() |
void |
setConnectionFactory(javax.jms.ConnectionFactory connectionFactory) |
getAnonymousPublisher, getCurrentMessage, getMBeanName, getPublisher, getPublisher, getPublisher, getResourceProperty, getSubscription, getSubscriptions, handleNotify, handleRegisterPublisher, handleSubscribe, notify, registerPublisher, subscribe, unsubscribegetAddress, getEpr, getManager, getName, getWSDLLocation, register, setAddress, setManager, unregisterclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetAddress, getName, register, unregisterpublic JmsNotificationBroker(String name)
public JmsNotificationBroker(String name, javax.jms.ConnectionFactory connectionFactory)
public void init()
throws Exception
init in class AbstractNotificationBrokerExceptionpublic void destroy()
throws Exception
destroy in class AbstractNotificationBrokerExceptionprotected AbstractPublisher createPublisher(String name)
createPublisher in class AbstractNotificationBrokerprotected AbstractSubscription createSubscription(String name)
createSubscription in class AbstractNotificationBrokerprotected abstract JmsSubscription createJmsSubscription(String name)
protected abstract JmsPublisher createJmsPublisher(String name)
public javax.jms.ConnectionFactory getConnectionFactory()
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
protected GetResourcePropertyResponse handleGetResourceProperty(QName property) throws ResourceUnavailableFault, ResourceUnknownFault, InvalidResourcePropertyQNameFault
handleGetResourceProperty in class AbstractNotificationBrokerResourceUnavailableFaultResourceUnknownFaultInvalidResourcePropertyQNameFaultApache CXF