com.caucho.jms.connection

Class TopicConnectionImpl

java.lang.Object

com.caucho.jms.connection.ConnectionImpl

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

Constructors

Constructor and Description
TopicConnectionImpl(ConnectionFactoryImpl factory) Create a new topic connection.
TopicConnectionImpl(ConnectionFactoryImpl factory, boolean isXA) Create a new topic connection.

Method Summary

Modifier and Type	Method and Description
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