public class JMSTopicSubscriber extends JMSConsumer
RECEIVEMODE_NOWAIT, RECEIVEMODE_WAIT
JMS_LOGGER, NO_TX, QUEUE, SESSION_TX, TOPIC
Constructor and Description |
---|
JMSTopicSubscriber(java.lang.String destinationName,
java.lang.String selector,
javax.jms.Session session,
java.util.Properties env) |
JMSTopicSubscriber(java.lang.String destinationName,
java.lang.String selector,
javax.jms.Session session,
java.lang.String subscriptionName,
java.util.Properties env) |
JMSTopicSubscriber(java.lang.String destinationName,
java.lang.String conFactoryName,
java.lang.String selector,
int txMode,
java.util.Properties env) |
JMSTopicSubscriber(java.lang.String destinationName,
java.lang.String conFactoryName,
java.lang.String selector,
int txMode,
java.lang.String subscriptionName,
java.util.Properties env) |
JMSTopicSubscriber(java.lang.String destinationName,
java.lang.String conFactoryName,
java.lang.String selector,
int txMode,
java.lang.String subscriptionName,
java.util.Properties env,
java.lang.String providerUserName,
java.lang.String providerPassword) |
Modifier and Type | Method and Description |
---|---|
JMSClient |
createClientInSession()
Creates another JMSClient of the same type in this clients Session.
|
void |
unsubscribe()
Unsubscribe the durable subscription
subscriptionName . |
close, createClientInSession, createJMSProducerInSession, getMessage
commitTx, getDestinationName, getEnvironment, getProviderPassword, getProviderUserName, getSession, isValid, rollbackTx
public JMSTopicSubscriber(java.lang.String destinationName, java.lang.String conFactoryName, java.lang.String selector, int txMode, java.lang.String subscriptionName, java.util.Properties env) throws MXException
destinationName
- the JNDI name of the Destination.conFactoryName
- the JNDI name of the ConnectionFactory.selector
- The message selector for the MessageConsumer.txMode
- The transaction mode for the JMS client Session.subscriptionName
- The subscription name in case of subscribing to a Topic.env
- The env properties to create an InitialContext.MXException
public JMSTopicSubscriber(java.lang.String destinationName, java.lang.String selector, javax.jms.Session session, java.lang.String subscriptionName, java.util.Properties env) throws MXException
destinationName
- the JNDI name of the Destination.selector
- The message selector for the MessageConsumer.session
- the JMS session from which the client should be created.subscriptionName
- The subscription name in case of subscribing to a Topic.env
- The env properties to create an InitialContext.MXException
public JMSTopicSubscriber(java.lang.String destinationName, java.lang.String conFactoryName, java.lang.String selector, int txMode, java.util.Properties env) throws java.lang.Exception
destinationName
- the JNDI name of the Destination.conFactoryName
- the JNDI name of the ConnectionFactory.selector
- The message selector for the MessageConsumer.txMode
- The transaction mode for the JMS client Session.env
- The env properties to create an InitialContext.java.lang.Exception
public JMSTopicSubscriber(java.lang.String destinationName, java.lang.String selector, javax.jms.Session session, java.util.Properties env) throws MXException
destinationName
- the JNDI name of the Destination.selector
- The message selector for the MessageConsumer.session
- the JMS session from which the client should be created.env
- The env properties to create an InitialContext.MXException
public JMSTopicSubscriber(java.lang.String destinationName, java.lang.String conFactoryName, java.lang.String selector, int txMode, java.lang.String subscriptionName, java.util.Properties env, java.lang.String providerUserName, java.lang.String providerPassword) throws MXException
destinationName
- the JNDI name of the Destination.conFactoryName
- the JNDI name of the ConnectionFactory.selector
- The message selector for the MessageConsumer.txMode
- The transaction mode for the JMS client Session.subscriptionName
- The subscription name in case of subscribing to a Topic.env
- The env properties to create an InitialContext.providerUserName
- The provider connection user.providerPassword
- The provider connection password.MXException
public void unsubscribe() throws java.lang.Exception
subscriptionName
.java.lang.Exception
public JMSClient createClientInSession() throws MXException
JMSClient
createClientInSession
in class JMSConsumer
MXException