test_class.file: pooled-jms/src/test/java/org/messaginghub/pooled/jms/JmsPoolQueueSenderTest.java
test_class.identifier: JmsPoolQueueSenderTest
test_class.superclass: extends JmsPoolTestSupport
test_case.body: @Test
      public void testSendToQueueWithOverrides() throws JMSException {
          JmsPoolConnection connection = (JmsPoolConnection) cf.createTopicConnection();
          QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
          Queue queue = session.createTemporaryQueue();
          QueueSender sender = session.createSender(null);
  
          final AtomicBoolean sent = new AtomicBoolean();
          MockJMSConnection mockConnection = (MockJMSConnection) connection.getConnection();
          mockConnection.addConnectionListener(new MockJMSDefaultConnectionListener() {
  
              @Override
              public void onMessageSend(MockJMSSession session, MockJMSMessageProducer producer, Message message) throws JMSException {
                  assertEquals(DeliveryMode.PERSISTENT, message.getJMSDeliveryMode());
                  assertEquals(9, message.getJMSPriority());
                  assertTrue(message.getJMSExpiration() != 0);
  
                  sent.set(true);
              }
          });
  
          sender.send(queue, session.createTextMessage(), DeliveryMode.PERSISTENT, 9, 100);
  
          assertTrue(sent.get());
      }
test_case.class_method_signature: JmsPoolQueueSenderTest.testSendToQueueWithOverrides()
test_case.full_signature: @Test public void testSendToQueueWithOverrides()
test_case.identifier: testSendToQueueWithOverrides
test_case.invocations: createTopicConnection createQueueSession createTemporaryQueue createSender getConnection addConnectionListener assertEquals getJMSDeliveryMode assertEquals getJMSPriority assertTrue getJMSExpiration set send createTextMessage assertTrue get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSendToQueueWithOverrides()
focal_class.file: pooled-jms/src/main/java/org/messaginghub/pooled/jms/JmsPoolQueueSender.java
focal_class.identifier: JmsPoolQueueSender
focal_class.interfaces: implements QueueSender, AutoCloseable
focal_class.class_method_signature: JmsPoolQueueSender.JmsPoolQueueSender(JmsPoolSession session, QueueSender messageProducer, Destination destination, AtomicInteger refCount)
focal_class.full_signature: public  JmsPoolQueueSender(JmsPoolSession session, QueueSender messageProducer, Destination destination, AtomicInteger refCount)
focal_class.identifier: JmsPoolQueueSender
focal_class.modifiers: public
focal_class.parameters: (JmsPoolSession session, QueueSender messageProducer, Destination destination, AtomicInteger refCount)
focal_class.signature:  JmsPoolQueueSender(JmsPoolSession session, QueueSender messageProducer, Destination destination, AtomicInteger refCount)
focal_class.class_method_signature: JmsPoolQueueSender.send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine)
focal_class.full_signature: @Override public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine)
focal_class.identifier: send
focal_class.modifiers: @Override public
focal_class.parameters: (Queue queue, Message message, int deliveryMode, int priority, long timeToLine)
focal_class.return: void
focal_class.signature: void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine)
focal_class.class_method_signature: JmsPoolQueueSender.send(Queue queue, Message message)
focal_class.full_signature: @Override public void send(Queue queue, Message message)
focal_class.identifier: send
focal_class.modifiers: @Override public
focal_class.parameters: (Queue queue, Message message)
focal_class.return: void
focal_class.signature: void send(Queue queue, Message message)
focal_class.class_method_signature: JmsPoolQueueSender.getQueue()
focal_class.full_signature: @Override public Queue getQueue()
focal_class.identifier: getQueue
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Queue
focal_class.signature: Queue getQueue()
focal_class.class_method_signature: JmsPoolQueueSender.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: JmsPoolQueueSender.getQueueSender()
focal_class.full_signature: public QueueSender getQueueSender()
focal_class.identifier: getQueueSender
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: QueueSender
focal_class.signature: QueueSender getQueueSender()
focal_class.superclass: extends JmsPoolMessageProducer
focal_method.body: @Override
      public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine) throws JMSException {
          super.send(queue, message, deliveryMode, priority, timeToLine);
      }
focal_method.class_method_signature: JmsPoolQueueSender.send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine)
focal_method.full_signature: @Override public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine)
focal_method.identifier: send
focal_method.invocations: send
focal_method.modifiers: @Override public
focal_method.parameters: (Queue queue, Message message, int deliveryMode, int priority, long timeToLine)
focal_method.return: void
focal_method.signature: void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine)