test_class.declarator: LOG = LoggerFactory.getLogger(JmsPoolConnectionTest.class)
test_class.modifier: private static final
test_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(JmsPoolConnectionTest.class);
test_class.type: Logger
test_class.var_name: LOG
test_class.file: pooled-jms/src/test/java/org/messaginghub/pooled/jms/JmsPoolConnectionTest.java
test_class.identifier: JmsPoolConnectionTest
test_class.superclass: extends JmsPoolTestSupport
test_case.body: @Test(timeout = 60000)
      public void testCreateSession() throws Exception {
          Connection connection = cf.createConnection();
  
          Session session1 = connection.createSession();
          Session session2 = connection.createSession();
  
          assertNotSame(session1, session2);
          assertEquals(session1.getAcknowledgeMode(), Session.AUTO_ACKNOWLEDGE);
          assertEquals(session2.getAcknowledgeMode(), Session.AUTO_ACKNOWLEDGE);
  
          JmsPoolSession wrapperSession1 = (JmsPoolSession) session1;
          JmsPoolSession wrapperSession2 = (JmsPoolSession) session2;
  
          assertNotSame(wrapperSession1.getSession(), wrapperSession2.getSession());
      }
test_case.class_method_signature: JmsPoolConnectionTest.testCreateSession()
test_case.full_signature: @Test(timeout = 60000) public void testCreateSession()
test_case.identifier: testCreateSession
test_case.invocations: createConnection createSession createSession assertNotSame assertEquals getAcknowledgeMode assertEquals getAcknowledgeMode assertNotSame getSession getSession
test_case.modifiers: @Test(timeout = 60000) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCreateSession()
focal_class.declarator: LOG = LoggerFactory.getLogger(JmsPoolConnection.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(JmsPoolConnection.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: connection
focal_class.modifier: protected
focal_class.original_string: protected PooledConnection connection;
focal_class.type: PooledConnection
focal_class.var_name: connection
focal_class.declarator: closed = new AtomicBoolean()
focal_class.modifier: private final
focal_class.original_string: private final AtomicBoolean closed = new AtomicBoolean();
focal_class.type: AtomicBoolean
focal_class.var_name: closed
focal_class.declarator: connTempQueues = new CopyOnWriteArrayList<TemporaryQueue>()
focal_class.modifier: private final
focal_class.original_string: private final List<TemporaryQueue> connTempQueues = new CopyOnWriteArrayList<TemporaryQueue>();
focal_class.type: List<TemporaryQueue>
focal_class.var_name: connTempQueues
focal_class.declarator: connTempTopics = new CopyOnWriteArrayList<TemporaryTopic>()
focal_class.modifier: private final
focal_class.original_string: private final List<TemporaryTopic> connTempTopics = new CopyOnWriteArrayList<TemporaryTopic>();
focal_class.type: List<TemporaryTopic>
focal_class.var_name: connTempTopics
focal_class.declarator: loanedSessions = new CopyOnWriteArrayList<JmsPoolSession>()
focal_class.modifier: private final
focal_class.original_string: private final List<JmsPoolSession> loanedSessions = new CopyOnWriteArrayList<JmsPoolSession>();
focal_class.type: List<JmsPoolSession>
focal_class.var_name: loanedSessions
focal_class.file: pooled-jms/src/main/java/org/messaginghub/pooled/jms/JmsPoolConnection.java
focal_class.identifier: JmsPoolConnection
focal_class.interfaces: implements TopicConnection, QueueConnection, JmsPoolSessionEventListener, AutoCloseable
focal_class.class_method_signature: JmsPoolConnection.JmsPoolConnection(PooledConnection pool)
focal_class.full_signature: public  JmsPoolConnection(PooledConnection pool)
focal_class.identifier: JmsPoolConnection
focal_class.modifiers: public
focal_class.parameters: (PooledConnection pool)
focal_class.signature:  JmsPoolConnection(PooledConnection pool)
focal_class.class_method_signature: JmsPoolConnection.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: JmsPoolConnection.start()
focal_class.full_signature: @Override public void start()
focal_class.identifier: start
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void start()
focal_class.class_method_signature: JmsPoolConnection.stop()
focal_class.full_signature: @Override public void stop()
focal_class.identifier: stop
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stop()
focal_class.class_method_signature: JmsPoolConnection.getMetaData()
focal_class.full_signature: @Override public ConnectionMetaData getMetaData()
focal_class.identifier: getMetaData
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ConnectionMetaData
focal_class.signature: ConnectionMetaData getMetaData()
focal_class.class_method_signature: JmsPoolConnection.getExceptionListener()
focal_class.full_signature: @Override public ExceptionListener getExceptionListener()
focal_class.identifier: getExceptionListener
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ExceptionListener
focal_class.signature: ExceptionListener getExceptionListener()
focal_class.class_method_signature: JmsPoolConnection.setExceptionListener(ExceptionListener exceptionListener)
focal_class.full_signature: @Override public void setExceptionListener(ExceptionListener exceptionListener)
focal_class.identifier: setExceptionListener
focal_class.modifiers: @Override public
focal_class.parameters: (ExceptionListener exceptionListener)
focal_class.return: void
focal_class.signature: void setExceptionListener(ExceptionListener exceptionListener)
focal_class.class_method_signature: JmsPoolConnection.getClientID()
focal_class.full_signature: @Override public String getClientID()
focal_class.identifier: getClientID
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getClientID()
focal_class.class_method_signature: JmsPoolConnection.setClientID(String clientID)
focal_class.full_signature: @Override public void setClientID(String clientID)
focal_class.identifier: setClientID
focal_class.modifiers: @Override public
focal_class.parameters: (String clientID)
focal_class.return: void
focal_class.signature: void setClientID(String clientID)
focal_class.class_method_signature: JmsPoolConnection.createConnectionConsumer(Destination destination, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.full_signature: @Override public ConnectionConsumer createConnectionConsumer(Destination destination, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.identifier: createConnectionConsumer
focal_class.modifiers: @Override public
focal_class.parameters: (Destination destination, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.return: ConnectionConsumer
focal_class.signature: ConnectionConsumer createConnectionConsumer(Destination destination, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.class_method_signature: JmsPoolConnection.createConnectionConsumer(Topic topic, String s, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.full_signature: @Override public ConnectionConsumer createConnectionConsumer(Topic topic, String s, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.identifier: createConnectionConsumer
focal_class.modifiers: @Override public
focal_class.parameters: (Topic topic, String s, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.return: ConnectionConsumer
focal_class.signature: ConnectionConsumer createConnectionConsumer(Topic topic, String s, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.class_method_signature: JmsPoolConnection.createDurableConnectionConsumer(Topic topic, String selector, String s1, ServerSessionPool serverSessionPool, int i)
focal_class.full_signature: @Override public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String selector, String s1, ServerSessionPool serverSessionPool, int i)
focal_class.identifier: createDurableConnectionConsumer
focal_class.modifiers: @Override public
focal_class.parameters: (Topic topic, String selector, String s1, ServerSessionPool serverSessionPool, int i)
focal_class.return: ConnectionConsumer
focal_class.signature: ConnectionConsumer createDurableConnectionConsumer(Topic topic, String selector, String s1, ServerSessionPool serverSessionPool, int i)
focal_class.class_method_signature: JmsPoolConnection.createSharedDurableConnectionConsumer(Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.full_signature: @Override public ConnectionConsumer createSharedDurableConnectionConsumer(Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.identifier: createSharedDurableConnectionConsumer
focal_class.modifiers: @Override public
focal_class.parameters: (Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.return: ConnectionConsumer
focal_class.signature: ConnectionConsumer createSharedDurableConnectionConsumer(Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.class_method_signature: JmsPoolConnection.createSharedConnectionConsumer(Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.full_signature: @Override public ConnectionConsumer createSharedConnectionConsumer(Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.identifier: createSharedConnectionConsumer
focal_class.modifiers: @Override public
focal_class.parameters: (Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.return: ConnectionConsumer
focal_class.signature: ConnectionConsumer createSharedConnectionConsumer(Topic topic, String subscriptionName, String selector, ServerSessionPool sessionPool, int maxMessages)
focal_class.class_method_signature: JmsPoolConnection.createConnectionConsumer(Queue queue, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.full_signature: @Override public ConnectionConsumer createConnectionConsumer(Queue queue, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.identifier: createConnectionConsumer
focal_class.modifiers: @Override public
focal_class.parameters: (Queue queue, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.return: ConnectionConsumer
focal_class.signature: ConnectionConsumer createConnectionConsumer(Queue queue, String selector, ServerSessionPool serverSessionPool, int maxMessages)
focal_class.class_method_signature: JmsPoolConnection.createQueueSession(boolean transacted, int ackMode)
focal_class.full_signature: @Override public QueueSession createQueueSession(boolean transacted, int ackMode)
focal_class.identifier: createQueueSession
focal_class.modifiers: @Override public
focal_class.parameters: (boolean transacted, int ackMode)
focal_class.return: QueueSession
focal_class.signature: QueueSession createQueueSession(boolean transacted, int ackMode)
focal_class.class_method_signature: JmsPoolConnection.createTopicSession(boolean transacted, int ackMode)
focal_class.full_signature: @Override public TopicSession createTopicSession(boolean transacted, int ackMode)
focal_class.identifier: createTopicSession
focal_class.modifiers: @Override public
focal_class.parameters: (boolean transacted, int ackMode)
focal_class.return: TopicSession
focal_class.signature: TopicSession createTopicSession(boolean transacted, int ackMode)
focal_class.class_method_signature: JmsPoolConnection.createSession()
focal_class.full_signature: @Override public Session createSession()
focal_class.identifier: createSession
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Session
focal_class.signature: Session createSession()
focal_class.class_method_signature: JmsPoolConnection.createSession(int sessionMode)
focal_class.full_signature: @Override public Session createSession(int sessionMode)
focal_class.identifier: createSession
focal_class.modifiers: @Override public
focal_class.parameters: (int sessionMode)
focal_class.return: Session
focal_class.signature: Session createSession(int sessionMode)
focal_class.class_method_signature: JmsPoolConnection.createSession(boolean transacted, int ackMode)
focal_class.full_signature: @Override public Session createSession(boolean transacted, int ackMode)
focal_class.identifier: createSession
focal_class.modifiers: @Override public
focal_class.parameters: (boolean transacted, int ackMode)
focal_class.return: Session
focal_class.signature: Session createSession(boolean transacted, int ackMode)
focal_class.class_method_signature: JmsPoolConnection.onTemporaryQueueCreate(TemporaryQueue tempQueue)
focal_class.full_signature: @Override public void onTemporaryQueueCreate(TemporaryQueue tempQueue)
focal_class.identifier: onTemporaryQueueCreate
focal_class.modifiers: @Override public
focal_class.parameters: (TemporaryQueue tempQueue)
focal_class.return: void
focal_class.signature: void onTemporaryQueueCreate(TemporaryQueue tempQueue)
focal_class.class_method_signature: JmsPoolConnection.onTemporaryTopicCreate(TemporaryTopic tempTopic)
focal_class.full_signature: @Override public void onTemporaryTopicCreate(TemporaryTopic tempTopic)
focal_class.identifier: onTemporaryTopicCreate
focal_class.modifiers: @Override public
focal_class.parameters: (TemporaryTopic tempTopic)
focal_class.return: void
focal_class.signature: void onTemporaryTopicCreate(TemporaryTopic tempTopic)
focal_class.class_method_signature: JmsPoolConnection.onSessionClosed(JmsPoolSession session)
focal_class.full_signature: @Override public void onSessionClosed(JmsPoolSession session)
focal_class.identifier: onSessionClosed
focal_class.modifiers: @Override public
focal_class.parameters: (JmsPoolSession session)
focal_class.return: void
focal_class.signature: void onSessionClosed(JmsPoolSession session)
focal_class.class_method_signature: JmsPoolConnection.getConnection()
focal_class.full_signature: public Connection getConnection()
focal_class.identifier: getConnection
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Connection
focal_class.signature: Connection getConnection()
focal_class.class_method_signature: JmsPoolConnection.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.class_method_signature: JmsPoolConnection.cleanupConnectionTemporaryDestinations()
focal_class.full_signature: protected void cleanupConnectionTemporaryDestinations()
focal_class.identifier: cleanupConnectionTemporaryDestinations
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cleanupConnectionTemporaryDestinations()
focal_class.class_method_signature: JmsPoolConnection.cleanupAllLoanedSessions()
focal_class.full_signature: protected void cleanupAllLoanedSessions()
focal_class.identifier: cleanupAllLoanedSessions
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cleanupAllLoanedSessions()
focal_class.class_method_signature: JmsPoolConnection.getNumSessions()
focal_class.full_signature: public int getNumSessions()
focal_class.identifier: getNumSessions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getNumSessions()
focal_class.class_method_signature: JmsPoolConnection.getNumActiveSessions()
focal_class.full_signature: public int getNumActiveSessions()
focal_class.identifier: getNumActiveSessions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getNumActiveSessions()
focal_class.class_method_signature: JmsPoolConnection.getNumtIdleSessions()
focal_class.full_signature: public int getNumtIdleSessions()
focal_class.identifier: getNumtIdleSessions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getNumtIdleSessions()
focal_class.class_method_signature: JmsPoolConnection.checkClosed()
focal_class.full_signature: protected void checkClosed()
focal_class.identifier: checkClosed
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void checkClosed()
focal_method.body: @Override
      public Session createSession() throws JMSException {
          return createSession(false, Session.AUTO_ACKNOWLEDGE);
      }
focal_method.class_method_signature: JmsPoolConnection.createSession()
focal_method.full_signature: @Override public Session createSession()
focal_method.identifier: createSession
focal_method.invocations: createSession
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: Session
focal_method.signature: Session createSession()