/*

  * Copyright (C) The Apache Software Foundation. All rights reserved.

  *

  * This software is published under the terms of the Apache Software License

  * version 1.1, a copy of which has been included with this distribution in

  * the LICENSE file.

  *

  * $Id: XAMessenger.java 155459 2005-02-26 13:24:44Z dirkv $

  */

 package org.apache.commons.messenger;

 import javax.jms.Session;

 import javax.jms.XASession;

 import javax.transaction.Transaction;

 import javax.transaction.xa.XAResource;

 import org.apache.commons.logging.Log;

 import org.apache.commons.logging.LogFactory;

 /** <p><code>XAMessenger</code> is a default implementation of

  * Messenger which can also support XA transactions by enlisting and delisting

  * XAResources.

  * This is implemented as a seperate Messenger implementation to avoid the core

  * Messenger having a dependency on JTA.

  * .</p>

  *

  * @author <a href="mailto:jstrachan@apache.org">James Strachan</a>

  * @version $Revision: 155459 $

  */

 public class XAMessenger extends DefaultMessenger implements XACapable {

     /** Logger */

     private static final Log log = LogFactory.getLog(XAMessenger.class);

     public XAMessenger() {

     }

     // XACapable interface

     //-------------------------------------------------------------------------

         public void enlistResources(Transaction transaction) throws Exception {

                 XAResource resource = getXAResource();

                 if (resource != null) {

                         transaction.enlistResource(resource);

                 }

         }

         public void delistResources(Transaction transaction, int flag) throws Exception {

                 XAResource resource = getXAResource();

                 if (resource != null) {

                         transaction.delistResource(resource, flag);

                 }

         }

     // Implementation methods

     //-------------------------------------------------------------------------

     /**

      * @return the XAResource associated with this Messenger if one exists

      */

         protected XAResource getXAResource() throws Exception {

                 Session session = getMessengerSession().getSession();

                 if (session instanceof XASession) {

                         XASession xaSession = (XASession) session;

                         return xaSession.getXAResource();

                 }

                 return null;

         }

 }