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
|
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 |
xatc
protected javax.jms.XATopicConnection xatc
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 namepasswd
- 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
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