This documentation is for WSO2 Message Broker 3.0.0. View documentation for the latest release.
Due to a known issue do not use JDK1.8.0_151 with WSO2 products. Use JDK 1.8.0_144 until JDK 1.8.0_162-ea is released.

Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Run the ant command from <MB_HOME>/Samples/TransactionalPublisher directory.

Analyzing the output

You will get the following log in your console. The result log shown above explains how the transactional session has worked when publishing messages:

Code Block
linenumberstrue
run:
     [java] INFO : org.sample.jms.MainClass - ------Sample for Message Sending and Committing.------
    
[java] INFO : org.sample.jms.TransactionalQueuePublisher - Message sent : My First Message.
    
[java] INFO : org.sample.jms.QueueConsumer - No messages were received within 5 seconds.
  
  [java] INFO : org.sample.jms.TransactionalQueuePublisher - Message sent : My Second Message.
    
[java] INFO : org.sample.jms.TransactionalQueuePublisher - Committing messages.
     [java] INFO : org.sample.jms.QueueConsumer - Received message : My First Message.
 
   [java] INFO : org.sample.jms.QueueConsumer - Received message : My Second Message.
   
 [java] INFO : org.sample.jms.MainClass - ------Sample for Message Sending, Rollback and Committing.------
    
[java] INFO : org.sample.jms.TransactionalQueuePublisher - Message sent : My Third Message.
    
[java] INFO : org.sample.jms.QueueConsumer - No messages were received within 5 seconds.
  
  [java] INFO : org.sample.jms.TransactionalQueuePublisher - Rollbacks all uncommitted messages.
    
[java] INFO : org.sample.jms.TransactionalQueuePublisher - Message sent : My Forth Message.
    
[java] INFO : org.sample.jms.TransactionalQueuePublisher - Committing messages.
 
   [java] INFO : org.sample.jms.QueueConsumer - Received message : My Forth Message.
   
 [java] INFO : org.sample.jms.QueueConsumer - No messages were received within 5 seconds.
    
[java] INFO : org.sample.jms.TransactionalQueuePublisher - Shutting down publisher.
    
[java] INFO : org.sample.jms.QueueConsumer - Shutting down consumer.