org.jencks.pool
Class PooledSpringXAConnection
java.lang.Object
org.jencks.pool.PooledSpringXAConnection
- All Implemented Interfaces:
- Connection, QueueConnection, TopicConnection, XAConnection
- public class PooledSpringXAConnection
- extends Object
- implements TopicConnection, QueueConnection, XAConnection
Method Summary |
void |
close()
|
ConnectionConsumer |
createConnectionConsumer(Destination destination,
String selector,
ServerSessionPool serverSessionPool,
int maxMessages)
|
ConnectionConsumer |
createConnectionConsumer(Queue queue,
String selector,
ServerSessionPool serverSessionPool,
int maxMessages)
|
ConnectionConsumer |
createConnectionConsumer(Topic topic,
String s,
ServerSessionPool serverSessionPool,
int maxMessages)
|
ConnectionConsumer |
createDurableConnectionConsumer(Topic topic,
String selector,
String s1,
ServerSessionPool serverSessionPool,
int i)
|
QueueSession |
createQueueSession(boolean transacted,
int ackMode)
|
Session |
createSession(boolean transacted,
int ackMode)
|
TopicSession |
createTopicSession(boolean transacted,
int ackMode)
|
XASession |
createXASession()
|
String |
getClientID()
|
protected XAConnection |
getConnection()
|
ExceptionListener |
getExceptionListener()
|
ConnectionMetaData |
getMetaData()
|
PooledSpringXAConnectionFactory |
getPooledConnectionFactory()
|
PooledSpringXAConnection |
newInstance()
Factory method to create a new instance. |
void |
setClientID(String clientID)
|
void |
setExceptionListener(ExceptionListener exceptionListener)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PooledSpringXAConnection
public PooledSpringXAConnection(PooledSpringXAConnectionFactory pooledConnectionFactory,
TransactionManager transactionManager,
XAConnection connection)
PooledSpringXAConnection
public PooledSpringXAConnection(PooledSpringXAConnectionFactory pooledConnectionFactory,
TransactionManager transactionManager,
org.jencks.pool.PooledSpringXAConnection.ConnectionInfo connectionInfo,
XASessionPool sessionPool)
newInstance
public PooledSpringXAConnection newInstance()
- Factory method to create a new instance.
close
public void close()
throws JMSException
- Specified by:
close
in interface Connection
- Throws:
JMSException
start
public void start()
throws JMSException
- Specified by:
start
in interface Connection
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Specified by:
stop
in interface Connection
- Throws:
JMSException
createConnectionConsumer
public ConnectionConsumer createConnectionConsumer(Destination destination,
String selector,
ServerSessionPool serverSessionPool,
int maxMessages)
throws JMSException
- Specified by:
createConnectionConsumer
in interface Connection
- Throws:
JMSException
createConnectionConsumer
public ConnectionConsumer createConnectionConsumer(Topic topic,
String s,
ServerSessionPool serverSessionPool,
int maxMessages)
throws JMSException
- Specified by:
createConnectionConsumer
in interface TopicConnection
- Throws:
JMSException
createDurableConnectionConsumer
public ConnectionConsumer createDurableConnectionConsumer(Topic topic,
String selector,
String s1,
ServerSessionPool serverSessionPool,
int i)
throws JMSException
- Specified by:
createDurableConnectionConsumer
in interface TopicConnection
- Throws:
JMSException
getClientID
public String getClientID()
throws JMSException
- Specified by:
getClientID
in interface Connection
- Throws:
JMSException
getExceptionListener
public ExceptionListener getExceptionListener()
throws JMSException
- Specified by:
getExceptionListener
in interface Connection
- Throws:
JMSException
getMetaData
public ConnectionMetaData getMetaData()
throws JMSException
- Specified by:
getMetaData
in interface Connection
- Throws:
JMSException
setExceptionListener
public void setExceptionListener(ExceptionListener exceptionListener)
throws JMSException
- Specified by:
setExceptionListener
in interface Connection
- Throws:
JMSException
setClientID
public void setClientID(String clientID)
throws JMSException
- Specified by:
setClientID
in interface Connection
- Throws:
JMSException
createConnectionConsumer
public ConnectionConsumer createConnectionConsumer(Queue queue,
String selector,
ServerSessionPool serverSessionPool,
int maxMessages)
throws JMSException
- Specified by:
createConnectionConsumer
in interface QueueConnection
- Throws:
JMSException
createXASession
public XASession createXASession()
throws JMSException
- Specified by:
createXASession
in interface XAConnection
- Throws:
JMSException
createQueueSession
public QueueSession createQueueSession(boolean transacted,
int ackMode)
throws JMSException
- Specified by:
createQueueSession
in interface QueueConnection
- Throws:
JMSException
createTopicSession
public TopicSession createTopicSession(boolean transacted,
int ackMode)
throws JMSException
- Specified by:
createTopicSession
in interface TopicConnection
- Throws:
JMSException
createSession
public Session createSession(boolean transacted,
int ackMode)
throws JMSException
- Specified by:
createSession
in interface Connection
- Throws:
JMSException
getConnection
protected XAConnection getConnection()
throws JMSException
- Throws:
JMSException
getPooledConnectionFactory
public PooledSpringXAConnectionFactory getPooledConnectionFactory()
Copyright © 2005 LogicBlaze, Inc.. All Rights Reserved.