com.caucho.jms.connection
Class TopicConnectionImpl

java.lang.Object
  extended by com.caucho.jms.connection.ConnectionImpl
      extended by com.caucho.jms.connection.TopicConnectionImpl
All Implemented Interfaces:
Connection, TopicConnection, XAConnection, XATopicConnection

public class TopicConnectionImpl
extends ConnectionImpl
implements XATopicConnection

A sample queue connection factory.


Constructor Summary
TopicConnectionImpl(ConnectionFactoryImpl factory)
          Create a new topic connection.
TopicConnectionImpl(ConnectionFactoryImpl factory, boolean isXA)
          Create a new topic connection.
 
Method Summary
 ConnectionConsumer createConnectionConsumer(Topic topic, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)
          Creates a new consumer (optional)
 ConnectionConsumer createDurableConnectionConsumer(Topic topic, java.lang.String name, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)
          Creates a new consumer (optional)
 TopicSession createTopicSession(boolean transacted, int acknowledgeMode)
          Creates a new connection session.
 XATopicSession createXATopicSession()
          Creates a new connection session.
 
Methods inherited from class com.caucho.jms.connection.ConnectionImpl
addSession, assignClientID, checkOpen, close, createConnectionConsumer, createSession, createXASession, getClientID, getConnectionFactory, getExceptionListener, getMetaData, isXA, setClientID, setExceptionListener, start, stop, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.XAConnection
createSession, createXASession
 
Methods inherited from interface javax.jms.Connection
close, createConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
 

Constructor Detail

TopicConnectionImpl

public TopicConnectionImpl(ConnectionFactoryImpl factory,
                           boolean isXA)
Create a new topic connection.


TopicConnectionImpl

public TopicConnectionImpl(ConnectionFactoryImpl factory)
Create a new topic connection.

Method Detail

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Topic topic,
                                                   java.lang.String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
                                            throws JMSException
Creates a new consumer (optional)

Specified by:
createConnectionConsumer in interface TopicConnection
Throws:
JMSException

createDurableConnectionConsumer

public ConnectionConsumer createDurableConnectionConsumer(Topic topic,
                                                          java.lang.String name,
                                                          java.lang.String messageSelector,
                                                          ServerSessionPool sessionPool,
                                                          int maxMessages)
                                                   throws JMSException
Creates a new consumer (optional)

Specified by:
createDurableConnectionConsumer in interface Connection
Specified by:
createDurableConnectionConsumer in interface TopicConnection
Overrides:
createDurableConnectionConsumer in class ConnectionImpl
Throws:
JMSException

createTopicSession

public TopicSession createTopicSession(boolean transacted,
                                       int acknowledgeMode)
                                throws JMSException
Creates a new connection session.

Specified by:
createTopicSession in interface TopicConnection
Specified by:
createTopicSession in interface XATopicConnection
Throws:
JMSException

createXATopicSession

public XATopicSession createXATopicSession()
                                    throws JMSException
Creates a new connection session.

Specified by:
createXATopicSession in interface XATopicConnection
Throws:
JMSException