org.objectweb.jonas_jms
Class JTopicConnection

java.lang.Object
  |
  +--org.objectweb.jonas_jms.JConnection
        |
        +--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
           
protected  javax.jms.XATopicConnectionFactory xatcf
           
 
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.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)
          Create a TopicSession
 
Methods inherited from class org.objectweb.jonas_jms.JConnection
close, 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.Connection
close, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
 

Field Detail

xatc

protected javax.jms.XATopicConnection xatc

xatcf

protected javax.jms.XATopicConnectionFactory xatcf
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

JTopicConnection

public JTopicConnection(JConnectionFactory jcf,
                        javax.jms.XATopicConnectionFactory xatcf)
                 throws javax.jms.JMSException
Constructor of a JQueueConnection for an anonymous user.
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

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