org.huihoo.jfox.ms.jms.topic
Class TopicSessionImpl

java.lang.Object
  org.huihoo.jfox.ms.jms.base.SessionImpl
      org.huihoo.jfox.ms.jms.topic.TopicSessionImpl

All Implemented Interfaces:

java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession

public class TopicSessionImpl

extends SessionImpl

implements javax.jms.TopicSession

Created by IntelliJ IDEA. User: yong.cheng Date: 2003-5-20 Time: 21:49:58 To change this template use Options | File Templates.

Field Summary

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE

Constructor Summary

TopicSessionImpl(ConnectionImpl connection, boolean transacted, int acknowledgeMode)

Method Summary

javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
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()
javax.jms.Topic	createTopic(java.lang.String topicName)
void	unsubscribe(java.lang.String name)

Methods inherited from class org.huihoo.jfox.ms.jms.base.SessionImpl

addConsumer, close, commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getConnection, getMessageListener, getTransacted, isClosed, isTransacted, recover, rollback, run, sendMessage, setMessageListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.Session

close, commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getMessageListener, getTransacted, recover, rollback, run, setMessageListener

Constructor Detail

TopicSessionImpl

public TopicSessionImpl(ConnectionImpl connection,
                        boolean transacted,
                        int acknowledgeMode)

Method Detail

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.JMSException

Specified by:

createTopic in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

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

Throws:

javax.jms.JMSException

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name)
                                                  throws javax.jms.JMSException

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name,
                                                         java.lang.String messageSelector,
                                                         boolean noLocal)
                                                  throws javax.jms.JMSException

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException

Specified by:

createPublisher in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException

Specified by:

createTemporaryTopic in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException

Specified by:

unsubscribe in interface javax.jms.TopicSession

Throws:

javax.jms.JMSException