org.jencks.amqpool
Class PooledConnection
java.lang.Object
org.jencks.amqpool.PooledConnection
- All Implemented Interfaces:
- javax.jms.Connection, javax.jms.QueueConnection, javax.jms.TopicConnection
public class PooledConnection
- extends java.lang.Object
- implements javax.jms.TopicConnection, javax.jms.QueueConnection
Represents a proxy Connection
which is-a TopicConnection
and
QueueConnection
which is pooled and on close()
will return
itself to the sessionPool.
NOTE this implementation is only intended for use when sending
messages.
It does not deal with pooling of consumers; for that look at a library like
Jencks such as in
this example
- Version:
- $Revision: 171 $
Method Summary |
protected void |
assertNotClosed()
|
void |
close()
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Destination destination,
java.lang.String selector,
javax.jms.ServerSessionPool serverSessionPool,
int maxMessages)
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
java.lang.String selector,
javax.jms.ServerSessionPool serverSessionPool,
int maxMessages)
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
java.lang.String s,
javax.jms.ServerSessionPool serverSessionPool,
int maxMessages)
|
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
java.lang.String selector,
java.lang.String s1,
javax.jms.ServerSessionPool serverSessionPool,
int i)
|
javax.jms.QueueSession |
createQueueSession(boolean transacted,
int ackMode)
|
javax.jms.Session |
createSession(boolean transacted,
int ackMode)
|
protected org.apache.activemq.ActiveMQSession |
createSession(SessionKey key)
|
javax.jms.TopicSession |
createTopicSession(boolean transacted,
int ackMode)
|
java.lang.String |
getClientID()
|
javax.jms.ExceptionListener |
getExceptionListener()
|
javax.jms.ConnectionMetaData |
getMetaData()
|
PooledConnection |
newInstance()
Factory method to create a new instance. |
void |
setClientID(java.lang.String clientID)
|
void |
setExceptionListener(javax.jms.ExceptionListener exceptionListener)
|
void |
start()
|
void |
stop()
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
PooledConnection
public PooledConnection(ConnectionPool pool)
newInstance
public PooledConnection newInstance()
- Factory method to create a new instance.
close
public void close()
throws javax.jms.JMSException
- Specified by:
close
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
start
public void start()
throws javax.jms.JMSException
- Specified by:
start
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
stop
public void stop()
throws javax.jms.JMSException
- Specified by:
stop
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination,
java.lang.String selector,
javax.jms.ServerSessionPool serverSessionPool,
int maxMessages)
throws javax.jms.JMSException
- Specified by:
createConnectionConsumer
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
java.lang.String s,
javax.jms.ServerSessionPool serverSessionPool,
int maxMessages)
throws javax.jms.JMSException
- Specified by:
createConnectionConsumer
in interface javax.jms.TopicConnection
- Throws:
javax.jms.JMSException
createDurableConnectionConsumer
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
java.lang.String selector,
java.lang.String s1,
javax.jms.ServerSessionPool serverSessionPool,
int i)
throws javax.jms.JMSException
- Specified by:
createDurableConnectionConsumer
in interface javax.jms.Connection
- Specified by:
createDurableConnectionConsumer
in interface javax.jms.TopicConnection
- Throws:
javax.jms.JMSException
getClientID
public java.lang.String getClientID()
throws javax.jms.JMSException
- Specified by:
getClientID
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
getExceptionListener
public javax.jms.ExceptionListener getExceptionListener()
throws javax.jms.JMSException
- Specified by:
getExceptionListener
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
getMetaData
public javax.jms.ConnectionMetaData getMetaData()
throws javax.jms.JMSException
- Specified by:
getMetaData
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
setExceptionListener
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
throws javax.jms.JMSException
- Specified by:
setExceptionListener
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
setClientID
public void setClientID(java.lang.String clientID)
throws javax.jms.JMSException
- Specified by:
setClientID
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
java.lang.String selector,
javax.jms.ServerSessionPool serverSessionPool,
int maxMessages)
throws javax.jms.JMSException
- Specified by:
createConnectionConsumer
in interface javax.jms.QueueConnection
- Throws:
javax.jms.JMSException
createQueueSession
public javax.jms.QueueSession createQueueSession(boolean transacted,
int ackMode)
throws javax.jms.JMSException
- Specified by:
createQueueSession
in interface javax.jms.QueueConnection
- Throws:
javax.jms.JMSException
createTopicSession
public javax.jms.TopicSession createTopicSession(boolean transacted,
int ackMode)
throws javax.jms.JMSException
- Specified by:
createTopicSession
in interface javax.jms.TopicConnection
- Throws:
javax.jms.JMSException
createSession
public javax.jms.Session createSession(boolean transacted,
int ackMode)
throws javax.jms.JMSException
- Specified by:
createSession
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
assertNotClosed
protected void assertNotClosed()
throws org.apache.activemq.AlreadyClosedException
- Throws:
org.apache.activemq.AlreadyClosedException
createSession
protected org.apache.activemq.ActiveMQSession createSession(SessionKey key)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 2010 LogicBlaze, Inc.. All Rights Reserved.