Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source
   * Copyright 2007, Red Hat Middleware LLC, and individual contributors
   * as indicated by the @author tags.
   * See the copyright.txt in the distribution for a full listing
   * of individual contributors.
   * This copyrighted material is made available to anyone wishing to use,
   * modify, copy, or redistribute it subject to the terms and conditions
   * of the GNU Lesser General Public License, v. 2.1.
  * This program is distributed in the hope that it will be useful, but WITHOUT A
  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
  * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
  * You should have received a copy of the GNU Lesser General Public License,
  * v.2.1 along with this distribution; if not, write to the Free Software
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
  * MA  02110-1301, USA.
  *
  * (C) 2007,
  * @author JBoss Inc.
  */
 package com.arjuna.mw.wst11.client;
 
 
Common base class for classes used to perform WS-Transaction context manipulation on SOAP messages.
 
 {
    
Handle the request.

Parameters:
soapMessage The current message context.
 
 
     public boolean handleOutboundMessage(final SOAPMessage soapMessage)
     {
         if (soapMessage == null)
         {
             return true ;
         }
 
         try
         {
             /*
              * There should either be an Atomic Transaction *or* a Business Activity
              * associated with the thread.
              */
             final TransactionManager transactionManager = TransactionManagerFactory.transactionManager() ;
             final com.arjuna.mw.wst11.BusinessActivityManager businessActivityManager = BusinessActivityManagerFactory.businessActivityManager() ;
 
             final Context atContext ;
             if (transactionManager != null)
             {
                 final TxContextImple txContext =
                     (TxContextImple)transactionManager.currentTransaction() ;
                 atContext = (txContext == null ? null : txContext.context()) ;
             }
             else
             {
                 atContext = null ;
             }
 
             final Context baContext ;
             if (businessActivityManager != null)
             {
                 final com.arjuna.mwlabs.wst11.ba.context.TxContextImple txContext =
                     (com.arjuna.mwlabs.wst11.ba.context.TxContextImple)businessActivityManager.currentTransaction() ;
                 baContext = (txContext == null ? null : txContext.context()) ;
             }
             else
             {
                 baContext = null ;
             }
 
             final CoordinationContextType coordinationContext ;
             if (atContext != null)
             {
                 coordinationContext = atContext.getCoordinationContext() ;
             }
             else if (baContext != null)
             {
                 coordinationContext = baContext.getCoordinationContext() ;
            }
            else
            {
                coordinationContext = null ;
            }
            if (coordinationContext != null)
            {
                final SOAPEnvelope env = soapMessage.getSOAPPart().getEnvelope() ;
                SOAPHeader header = env.getHeader() ;
                if (header == null)
                {
                    header = env.addHeader() ;
                }
                final SOAPHeaderElement headerElement = header.addHeaderElement(name) ;
                headerElement.setMustUnderstand(true) ;
                CoordinationContextHelper.serialise(coordinationContextheaderElement) ;
            }
        }
        catch (final Throwable th) {
            ..warn_mw_wst11_client_JaxHC11P_1("com.arjuna.mw.wst11.client.JaxBaseHeaderContextProcessor.handleRequest()"th);
        }
        return true ;
    }

    
Resume the current transaction.
    protected void resumeTransaction(final SOAPMessage soapMessage)
    {
        if (soapMessage != null)
        {
            try
            {
                final SOAPEnvelope soapEnvelope = soapMessage.getSOAPPart().getEnvelope() ;
                final SOAPHeaderElement soapHeaderElement = getHeaderElement(soapEnvelope..) ;
                if (soapHeaderElement != null)
                {
                    final CoordinationContextType cc = CoordinationContextHelper.deserialise(soapHeaderElement) ;
                    if (cc != null)
                    {
                        final String coordinationType = cc.getCoordinationType() ;
                        if (..equals(coordinationType))
                        {
                            final TxContext txContext = new TxContextImple(cc) ;
                            TransactionManagerFactory.transactionManager().resume(txContext) ;
                        }
                        else if (..equals(coordinationType))
                        {
                            final TxContext txContext = new com.arjuna.mwlabs.wst11.ba.context.TxContextImple(cc);
                            BusinessActivityManagerFactory.businessActivityManager().resume(txContext) ;
                        }
                        else {
                            ..warn_mw_wst11_client_JaxHC11P_2("com.arjuna.mw.wst11.client.JaxBaseHeaderContextProcessor.resumeTransaction()"coordinationType);
                        }
                    }
                }
            }
            catch (final Throwable th) {
                ..warn_mw_wst11_client_JaxHC11P_1("com.arjuna.mw.wst11.client.JaxBaseHeaderContextProcessor.resumeTransaction()"th);
            }
        }
    }

    
Retrieve the first header matching the uri and name.

Parameters:
soapEnvelope The soap envelope containing the header.
uri The uri of the header element.
name The name of the header element.
Returns:
The header element or null if not found.
    private SOAPHeaderElement getHeaderElement(final SOAPEnvelope soapEnvelopefinal String urifinal String name)
        throws SOAPException
    {
        final SOAPHeader soapHeader = soapEnvelope.getHeader() ;
        if (soapHeader != null)
        {
            final Iterator headerIter = SOAPUtil.getChildElements(soapHeader) ;
            while(headerIter.hasNext())
            {
                final SOAPHeaderElement current = (SOAPHeaderElement)headerIter.next() ;
                final Name currentName = current.getElementName() ;
                if ((currentName != null) &&
                    match(namecurrentName.getLocalName()) &&
                    match(uricurrentName.getURI()))
                {
                    return current ;
                }
            }
        }
        return null ;
    }

    
Do the two references match?

Parameters:
lhs The first reference.
rhs The second reference.
Returns:
true if the references are both null or if they are equal.
    private boolean match(final Object lhsfinal Object rhs)
    {
        if (lhs == null)
        {
            return (rhs == null) ;
        }
        else
        {
            return lhs.equals(rhs) ;
        }
    }
New to GrepCode? Check out our FAQ X