トランザクションセッションのサンプルプログラム

• セッションを作成する場合、createQueueSessionメソッドの最初のパラメータは、トランザクションセッションを使用するためtrueに設定されます。
• メッセージの送信または削除は、それぞれセッションのcommitおよびrollbackメソッドを使用して、制御されます。メッセージは、セッションがコミットされるまで、「送信されません」。

package txSession;
                                                                           
import javax.naming.InitialContext;
                                                                           
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.QueueSender;
import javax.jms.DeliveryMode;
import javax.jms.QueueSession;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
                                                                           
public class TxSender
{
    public static void main(String[] args) throws Exception
    {
    |   // get the initial context
    |   InitialContext ctx = new InitialContext();
    |                                                                      
    |   // lookup the queue object
    |   Queue queue = (Queue) ctx.lookup("queue/queue0");
    |                                                                      
    |   // lookup the queue connection factory
    |   QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.
    |       lookup("queue/connectionFactory");
    |                                                                      
    |   // create a queue connection
    |   QueueConnection queueConn = connFactory.createQueueConnection();
    |                                                                      
    |   // create a queue session
    |   QueueSession queueSession = queueConn.createQueueSession(true,
    |       Session.DUPS_OK_ACKNOWLEDGE);
    |                                                                      
    |   // create a queue sender
    |   QueueSender queueSender = queueSession.createSender(queue);
    |   queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
    |                                                                      
    |   TextMessage part1 = queueSession.createTextMessage("part one");
    |   TextMessage part2 = queueSession.createTextMessage("part two");
    |   TextMessage part3 = queueSession.createTextMessage("part three");
    |   TextMessage last  = queueSession.createTextMessage("final");
    |                                                                      
    |   queueSender.send(part1);
    |   queueSender.send(part2);
    |   queueSender.send(part3);
    |   queueSender.send(last);
    |                                                                      
    |   // commit the send (actually put messages on queue)
    |   queueSession.commit();
    |                                                                      
    |   System.out.println("TxSender committed 4 messages");
    |                                                                      
    |   // close the queue connection
    |   queueConn.close();
    }
}

• 送信者の場合と同様に、createQueueSessionメソッドの最初パラメータは、トランザクションセッションを使用するためtrueに設定されます。2番目の引数は無視されます。
• メッセージの確認は、セッションのcommitメソッドおよびrollbackメソッドを使用して、制御されます。

トランザクションセッションのロールバックは、CLIENT_ACKNOWLEDGEを使用する受信者でrecoverメソッドを呼び出す場合に類似しています。commitへの最後の呼び出しから受信されたすべてのメッセージは、セッションのコンシューマに再配信されます。また、rollbackにより、前に説明したとおり、セッションのプロデューサにより送信されたすべてのメッセージが破棄されます。

TxReceiverクラスのソースは、次のとおりです。

package txSession;
                                                                           
import javax.naming.InitialContext;
                                                                           
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.QueueSession;
import javax.jms.QueueReceiver;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
                                                                           
public class TxReceiver
{
    public static void main(String[] args) throws Exception
    {
    |   // get the initial context
    |   InitialContext ctx = new InitialContext();
    |                                                                      
    |   // lookup the queue object
    |   Queue queue = (Queue) ctx.lookup("queue/queue0");
    |                                                                      
    |   // lookup the queue connection factory
    |   QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.
    |       lookup("queue/connectionFactory");
    |                                                                      
    |   // create a queue connection
    |   QueueConnection queueConn = connFactory.createQueueConnection();
    |                                                                      
    |   // create a queue session
    |   QueueSession queueSession = queueConn.createQueueSession(true,
    |       Session.AUTO_ACKNOWLEDGE);
    |                                                                      
    |   // create a queue receiver
    |   QueueReceiver queueReceiver = queueSession.createReceiver(queue);
    |                                                                      
    |   // start the connection
    |   queueConn.start();
    |                                                                      
    |   while (true)
    |   {
    |   |   TextMessage msg = (TextMessage) queueReceiver.receive();
    |   |   System.out.println(msg.getText());
    |   |   if (msg.getText().equals("final"))
    |   |   {
    |   |   |   queueSession.commit(); // acknowledge all
    |   |   |   break;
    |   |   }
    |   }
    |                                                                      
    |   // close the queue connection
    |   queueConn.close();
    }
}