org.exolab.jms.client
Class JmsTopicConnection

java.lang.Object
  |
  +--org.exolab.jms.client.JmsConnection
        |
        +--org.exolab.jms.client.JmsTopicConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.TopicConnection

Direct Known Subclasses:

JmsXATopicConnection

public class JmsTopicConnection

extends JmsConnection

implements javax.jms.TopicConnection

Version:

$Revision: 1.11 $ $Date: 2003/08/07 13:32:51 $

Author:

Jim Alateras

See Also:

TopicConnection

Constructor Summary

JmsTopicConnection(JmsTopicConnectionFactory factory, java.lang.String id, java.lang.String username, java.lang.String password)
Instantiate an instance of this connection using the specified client identity.

Method Summary

javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Topic topic, java.lang.String selector, javax.jms.ServerSessionPool pool, int maxMessages)
javax.jms.ConnectionConsumer	createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String selector, javax.jms.ServerSessionPool pool, int maxMessages)
javax.jms.TopicSession	createTopicSession(boolean transacted, int ackMode)

Methods inherited from class org.exolab.jms.client.JmsConnection

addSession, close, destroy, ensureOpen, getClientID, getConnectionId, getExceptionListener, getMetaData, getSessions, isManaged, isStopped, notifyExceptionListener, removeSession, setClientID, setExceptionListener, setModified, 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

JmsTopicConnection

public JmsTopicConnection(JmsTopicConnectionFactory factory,
                          java.lang.String id,
                          java.lang.String username,
                          java.lang.String password)
                   throws javax.jms.JMSException

Instantiate an instance of this connection using the specified client identity. The client identity is immutable and once set cannot be changed. To create a connection with another client identity the user must create another instance of this class. The factory is the creating entity.

If there are any problems during the creation process the JMSException is raised

Parameters:

factory - entity creating this object

username - client username

password - client password

id - client identity

Throws:

javax.jms.JMSException -

Method Detail

createTopicSession

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

Specified by:

createTopicSession in interface javax.jms.TopicConnection

createConnectionConsumer

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

Specified by:

createConnectionConsumer in interface javax.jms.TopicConnection

createDurableConnectionConsumer

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

Specified by:

createDurableConnectionConsumer in interface javax.jms.TopicConnection