Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

com.presumo.jms.client
Class JmsTopicSession  view JmsTopicSession download JmsTopicSession.java

java.lang.Object
  extended bycom.presumo.jms.router.RouterAdapter
      extended bycom.presumo.jms.client.JmsSession
          extended bycom.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.


Field Summary
private static com.presumo.util.log.Logger logger
           
 
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
 
Fields inherited from class com.presumo.jms.router.RouterAdapter
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Constructor Summary
JmsTopicSession(com.presumo.jms.router.Router router, boolean transacted, int acknowledgeMode, JmsConnection connx)
           
 
Method Summary
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
          Not Implemented (yet).
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
          Not Implemented (yet).
 javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
           
 javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
           
 javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal)
           
 javax.jms.TemporaryTopic createTemporaryTopic()
          Not Implemented.
 javax.jms.Topic createTopic(java.lang.String topicName)
          Creates a topic from the given string.
 void unsubscribe(java.lang.String name)
           
 
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 class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
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
 

Field Detail

logger

private static com.presumo.util.log.Logger logger
Constructor Detail

JmsTopicSession

public JmsTopicSession(com.presumo.jms.router.Router router,
                       boolean transacted,
                       int acknowledgeMode,
                       JmsConnection connx)
                throws javax.jms.JMSException
Method Detail

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