test_class.file: pooled-jms/src/test/java/org/messaginghub/pooled/jms/JmsPoolTopicPublisherTest.java
test_class.identifier: JmsPoolTopicPublisherTest
test_class.superclass: extends JmsPoolTestSupport
test_case.body: @Test
      public void testPublish() throws JMSException {
          JmsPoolConnection connection = (JmsPoolConnection) cf.createTopicConnection();
          TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
          Topic topic = session.createTemporaryTopic();
          TopicPublisher publisher = session.createPublisher(topic);
  
          final AtomicBoolean published = new AtomicBoolean();
          MockJMSConnection mockConnection = (MockJMSConnection) connection.getConnection();
          mockConnection.addConnectionListener(new MockJMSDefaultConnectionListener() {
  
              @Override
              public void onMessageSend(MockJMSSession session, MockJMSMessageProducer producer, Message message) throws JMSException {
                  assertTrue(message instanceof TextMessage);
                  published.set(true);
              }
          });
  
          publisher.publish(session.createTextMessage());
  
          assertTrue(published.get());
      }
test_case.class_method_signature: JmsPoolTopicPublisherTest.testPublish()
test_case.full_signature: @Test public void testPublish()
test_case.identifier: testPublish
test_case.invocations: createTopicConnection createTopicSession createTemporaryTopic createPublisher getConnection addConnectionListener assertTrue set publish createTextMessage assertTrue get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testPublish()
focal_class.file: pooled-jms/src/main/java/org/messaginghub/pooled/jms/JmsPoolTopicPublisher.java
focal_class.identifier: JmsPoolTopicPublisher
focal_class.interfaces: implements TopicPublisher, AutoCloseable
focal_class.class_method_signature: JmsPoolTopicPublisher.JmsPoolTopicPublisher(JmsPoolSession session, TopicPublisher messageProducer, Destination destination, AtomicInteger refCount)
focal_class.full_signature: public  JmsPoolTopicPublisher(JmsPoolSession session, TopicPublisher messageProducer, Destination destination, AtomicInteger refCount)
focal_class.identifier: JmsPoolTopicPublisher
focal_class.modifiers: public
focal_class.parameters: (JmsPoolSession session, TopicPublisher messageProducer, Destination destination, AtomicInteger refCount)
focal_class.signature:  JmsPoolTopicPublisher(JmsPoolSession session, TopicPublisher messageProducer, Destination destination, AtomicInteger refCount)
focal_class.class_method_signature: JmsPoolTopicPublisher.getTopic()
focal_class.full_signature: @Override public Topic getTopic()
focal_class.identifier: getTopic
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Topic
focal_class.signature: Topic getTopic()
focal_class.class_method_signature: JmsPoolTopicPublisher.publish(Message message)
focal_class.full_signature: @Override public void publish(Message message)
focal_class.identifier: publish
focal_class.modifiers: @Override public
focal_class.parameters: (Message message)
focal_class.return: void
focal_class.signature: void publish(Message message)
focal_class.class_method_signature: JmsPoolTopicPublisher.publish(Message message, int deliveryMode, int priority, long timeToLive)
focal_class.full_signature: @Override public void publish(Message message, int deliveryMode, int priority, long timeToLive)
focal_class.identifier: publish
focal_class.modifiers: @Override public
focal_class.parameters: (Message message, int deliveryMode, int priority, long timeToLive)
focal_class.return: void
focal_class.signature: void publish(Message message, int deliveryMode, int priority, long timeToLive)
focal_class.class_method_signature: JmsPoolTopicPublisher.publish(Topic topic, Message message)
focal_class.full_signature: @Override public void publish(Topic topic, Message message)
focal_class.identifier: publish
focal_class.modifiers: @Override public
focal_class.parameters: (Topic topic, Message message)
focal_class.return: void
focal_class.signature: void publish(Topic topic, Message message)
focal_class.class_method_signature: JmsPoolTopicPublisher.publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive)
focal_class.full_signature: @Override public void publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive)
focal_class.identifier: publish
focal_class.modifiers: @Override public
focal_class.parameters: (Topic topic, Message message, int deliveryMode, int priority, long timeToLive)
focal_class.return: void
focal_class.signature: void publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive)
focal_class.class_method_signature: JmsPoolTopicPublisher.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: JmsPoolTopicPublisher.getTopicPublisher()
focal_class.full_signature: public TopicPublisher getTopicPublisher()
focal_class.identifier: getTopicPublisher
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: TopicPublisher
focal_class.signature: TopicPublisher getTopicPublisher()
focal_class.superclass: extends JmsPoolMessageProducer
focal_method.body: @Override
      public void publish(Message message) throws JMSException {
          super.send(message);
      }
focal_method.class_method_signature: JmsPoolTopicPublisher.publish(Message message)
focal_method.full_signature: @Override public void publish(Message message)
focal_method.identifier: publish
focal_method.invocations: send
focal_method.modifiers: @Override public
focal_method.parameters: (Message message)
focal_method.return: void
focal_method.signature: void publish(Message message)