java.lang.Object
com.presumo.jms.router.RouterAdapter
com.presumo.jms.client.JmsSession
com.presumo.jms.client.JmsTopicSession
- All Implemented Interfaces:
- com.presumo.jms.message.MessageStateListener, com.presumo.jms.router.RoutingTarget, java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession
- public final class JmsTopicSession
- extends JmsSession
- implements javax.jms.TopicSession
Implementation of the interface javax.jms.TopicSession.
| Fields inherited from class com.presumo.jms.client.JmsSession |
acknowledgeMode, asynchCount, closed, connx, DURABLE_SUBSCRIBER_CLOSE, DURABLE_SUBSCRIBER_CRT, DURABLE_SUBSCRIBER_DELETE, joinedFilter, parser, QUEUE_BROWSER_CLOSE, QUEUE_BROWSER_CRT, QUEUE_RECEIVER_CLOSE, QUEUE_RECEIVER_CRT, router, transacted |
| Methods inherited from class com.presumo.jms.client.JmsSession |
acknowledge, addAsynch, addConsumer, addProducer, autoAcknowledge, close, commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, finalize, getMessageListener, getRoutingFilter, getTransacted, hasAsynchronousListeners, messageDeleted, messageRouted, needsFilterUpdates, recover, removeAsynch, removeConsumer, removeProducer, reportException, rollback, routeMessages, send, sendQueueRequest, setMessageListener, setRemoteRoutingFilter, setTargetID, start, stop, takeMessage |
| Methods inherited from class com.presumo.jms.router.RouterAdapter |
closeRouter, getNext, queueMessage, queueMessages, queueSize, run, setBatchSize, setMessageQueue, startRouter, stopRouter, timerTick |
| Methods inherited from interface javax.jms.Session |
close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener |
logger
private static com.presumo.util.log.Logger logger
JmsTopicSession
public JmsTopicSession(com.presumo.jms.router.Router router,
boolean transacted,
int acknowledgeMode,
JmsConnection connx)
throws javax.jms.JMSException
createTopic
public javax.jms.Topic createTopic(java.lang.String topicName)
throws javax.jms.JMSException
- Creates a topic from the given string. The topic name
can contain a wildcard represented by a "*".
- Specified by:
createTopic in interface javax.jms.TopicSession
createSubscriber
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
throws javax.jms.JMSException
- Specified by:
createSubscriber in interface javax.jms.TopicSession
createSubscriber
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
java.lang.String messageSelector,
boolean noLocal)
throws javax.jms.JMSException
- Specified by:
createSubscriber in interface javax.jms.TopicSession
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name)
throws javax.jms.JMSException
- Not Implemented (yet).
- Specified by:
createDurableSubscriber in interface javax.jms.TopicSession
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal)
throws javax.jms.JMSException
- Not Implemented (yet).
- Specified by:
createDurableSubscriber in interface javax.jms.TopicSession
createPublisher
public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
throws javax.jms.JMSException
- Specified by:
createPublisher in interface javax.jms.TopicSession
createTemporaryTopic
public javax.jms.TemporaryTopic createTemporaryTopic()
throws javax.jms.JMSException
- Not Implemented.
- Specified by:
createTemporaryTopic in interface javax.jms.TopicSession
unsubscribe
public void unsubscribe(java.lang.String name)
throws javax.jms.JMSException
- Specified by:
unsubscribe in interface javax.jms.TopicSession