Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source
   * Copyright 2006, 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) 2005-2006,
  * @author JBoss Inc.
  */
 /*
  * Copyright (C) 2003,
  *
  * Arjuna Technologies Limited,
  * Newcastle upon Tyne,
  * Tyne and Wear,
  * UK.
  *
  * $Id: BusinessActivityManagerImple.java,v 1.7.4.1 2005/11/22 10:36:08 kconner Exp $
  */
 
 package com.arjuna.mwlabs.wst11.ba.remote;
 
 
This is the interface that the core exposes in order to allow different types of participants to be enrolled. The messaging layer continues to work in terms of the registrar, but internally we map to one of these methods.
 
 
 {
     public BusinessActivityManagerImple()
     {
     }
 
     {
         try
         {
             boolean isSecure = ((TxContextImple)currentTransaction()).isSecure();
             final String address = ServiceRegistry.getRegistry().getServiceURI(.isSecure);
             final W3CEndpointReference participant = getParticipant(serviceendpointaddressid) ;
             final ParticipantCompletionParticipantEngine engine = new ParticipantCompletionParticipantEngine(idbaPMEndpointbap) ;
             ParticipantCompletionParticipantProcessor.getProcessor().activateParticipant(engineid) ;
 
             return new BAParticipantCompletionParticipantManagerStub(engine);
     	}
     	catch (com.arjuna.wsc.InvalidProtocolException ex)
     	{
     	    throw new SystemException(ex.toString());
     	}
     	catch (com.arjuna.wsc.InvalidStateException ex)
     	{
     	    throw new WrongStateException();
     	}
     	catch (com.arjuna.wsc.CannotRegisterException ex)
     	{
     	    throw new UnknownTransactionException();
    	}
    	catch (Throwable ex)
    	{
    	    ex.printStackTrace();
    	    throw new SystemException(ex.toString());
    	}
    }
    {
        boolean isSecure = ((TxContextImple)currentTransaction()).isSecure();
        try
        {
            final String address = ServiceRegistry.getRegistry().getServiceURI(.isSecure);
            final W3CEndpointReference participant = getParticipant(serviceendpointaddressid) ;
            final CoordinatorCompletionParticipantEngine engine = new CoordinatorCompletionParticipantEngine(idbaPMEndpointbawcp) ;
            CoordinatorCompletionParticipantProcessor.getProcessor().activateParticipant(engineid) ;
            return new BACoordinatorCompletionParticipantManagerStub(engine);
    	}
    	{
    	    throw new SystemException(ex.toString());
    	}
    	catch (com.arjuna.wsc.InvalidStateException ex)
    	{
    	    throw new WrongStateException();
    	}
    	{
    	    ex.printStackTrace();
    	    throw new UnknownTransactionException();
    	}
    	catch (Throwable ex)
    	{
    	    ex.printStackTrace();
    	    throw new SystemException(ex.toString());
    	}
    }
    public TxContext suspend () throws SystemException
    {
        return .suspend();
    }
    // resume overwrites. Should we check first a la JTA?
    public void resume (TxContext txthrows UnknownTransactionExceptionSystemException
    {
        .resume(tx);
    }
    public TxContext currentTransaction () throws SystemException
    {
        return .currentTransaction();
    }
    private final W3CEndpointReference registerParticipant(final W3CEndpointReference participantfinal String protocol)
    {
    	TxContextImple currentTx = null;
    	try
    	{
    	    currentTx = (TxContextImple.currentTransaction();
    	    if (currentTx == null)
        		throw new com.arjuna.wsc.NoActivityException();
            final CoordinationContextType coordinationContext = currentTx.context().getCoordinationContext() ;
            final String messageId = MessageId.getMessageId() ;
            return RegistrationCoordinator.register(coordinationContextmessageIdparticipantprotocol) ;
    	}
        catch (final SoapFault sf)
        {
            throw new SystemException(sf.getMessage());
        }
        catch (CannotRegisterException ex)
        {
            throw ex;
        }
    	catch (Exception ex)
    	{
    	    ex.printStackTrace();
    	    throw new SystemException(ex.toString());
    	}
    	finally
    	{
    	    try
    	    {
        		if (currentTx != null)
        		    .resume(currentTx);
    	    }
    	    catch (Exception ex)
    	    {
        		ex.printStackTrace();
    	    }
    	}
    }
    private W3CEndpointReference getParticipant(final QName servicefinal QName endpointfinal String addressfinal String id)
    {
        final W3CEndpointReferenceBuilder builder = new W3CEndpointReferenceBuilder();
        builder.serviceName(service);
        builder.endpointName(endpoint);
        builder.address(address);
        InstanceIdentifier.setEndpointInstanceIdentifier(builderid);
        return builder.build();
    }
    private ContextManager _ctxManager = new ContextManager();
New to GrepCode? Check out our FAQ X