org.objectweb.jonas_jms
Class JTopicConnection

java.lang.Object
  extended by org.objectweb.jonas_jms.JConnection
      extended by org.objectweb.jonas_jms.JTopicConnection
All Implemented Interfaces:
javax.jms.Connection, javax.jms.TopicConnection

public class JTopicConnection
extends JConnection
implements javax.jms.TopicConnection


Field Summary
protected  javax.jms.XATopicConnection xatc
           
 
Fields inherited from class org.objectweb.jonas_jms.JConnection
closed, globaltx, INTERNAL_USER_NAME, jcf, sessionlist, tm, user, xac
 
Constructor Summary
JTopicConnection(JConnectionFactory jcf, javax.jms.XATopicConnectionFactory xatcf)
          Constructor of a JQueueConnection for an anonymous user.
JTopicConnection(JConnectionFactory jcf, javax.jms.XATopicConnectionFactory xatcf, java.lang.String user, java.lang.String passwd)
          Constructor of a JTopicConnection for a specified user.
 
Method Summary
 javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
           
 javax.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode)
          Create a TopicSession
 
Methods inherited from class org.objectweb.jonas_jms.JConnection
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, finalClose, getClientID, getExceptionListener, getMetaData, getUser, sessionClose, sessionOpen, 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.TopicConnection
createDurableConnectionConsumer
 
Methods inherited from interface javax.jms.Connection
close, createConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
 

Field Detail

xatc

protected javax.jms.XATopicConnection xatc
Constructor Detail

JTopicConnection

public JTopicConnection(JConnectionFactory jcf,
                        javax.jms.XATopicConnectionFactory xatcf,
                        java.lang.String user,
                        java.lang.String passwd)
                 throws javax.jms.JMSException
Constructor of a JTopicConnection for a specified user.

Parameters:
user - user's name
passwd - user's password
Throws:
javax.jms.JMSException

JTopicConnection

public JTopicConnection(JConnectionFactory jcf,
                        javax.jms.XATopicConnectionFactory xatcf)
                 throws javax.jms.JMSException
Constructor of a JQueueConnection for an anonymous user.

Throws:
javax.jms.JMSException
Method Detail

createTopicSession

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

Specified by:
createTopicSession in interface javax.jms.TopicConnection
Parameters:
transacted - - if true, the session is transacted.
acknowledgeMode - - indicates whether the consumer or the client will acknowledge any messages it receives. This parameter will be ignored if the session is transacted.
Returns:
a newly created topic session.
Throws:
javax.jms.JMSException - - if JMS Connection fails to create a session.

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 - - if JMS Connection fails to create a ConnectionConsumer