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

java.lang.Object
  org.huihoo.jfox.ms.jms.base.ConnectionImpl
      org.huihoo.jfox.ms.jms.topic.TopicConnectionImpl

All Implemented Interfaces:

javax.jms.Connection, javax.jms.TopicConnection

public class TopicConnectionImpl

extends ConnectionImpl

implements javax.jms.TopicConnection

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

Constructor Summary

TopicConnectionImpl(ConnectionFactoryImpl connFactory, java.lang.String userName, java.lang.String password)

Method Summary

javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
javax.jms.ConnectionConsumer	createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
javax.jms.TopicSession	createTopicSession(boolean transacted, int acknowledgeMode)

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

addSession, close, getClientID, getExceptionListener, getMetaData, isClosed, isStopped, removeSession, setClientID, setExceptionListener, 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.Connection

close, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Constructor Detail

TopicConnectionImpl

public TopicConnectionImpl(ConnectionFactoryImpl connFactory,
                           java.lang.String userName,
                           java.lang.String password)

Method Detail

createTopicSession

public javax.jms.TopicSession createTopicSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException

Specified by:

createTopicSession in interface javax.jms.TopicConnection

Throws:

javax.jms.JMSException

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException

Specified by:

createConnectionConsumer in interface javax.jms.TopicConnection

Throws:

javax.jms.JMSException

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String subscriptionName,
                                                                    java.lang.String messageSelector,
                                                                    javax.jms.ServerSessionPool sessionPool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException

Specified by:

createDurableConnectionConsumer in interface javax.jms.TopicConnection

Throws:

javax.jms.JMSException