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.
  */
 package com.arjuna.webservices11.wsba.client;
 
 import  org.jboss.ws.api.addressing.MAPEndpoint;
 import  org.jboss.ws.api.addressing.MAP;
 import  org.jboss.ws.api.addressing.MAPBuilder;
 import  org.jboss.ws.api.addressing.MAPBuilderFactory;
 
The Client side of the Coordinator Participant Coordinator.

Author(s):
kevin
 
 {
    
The client singleton.
 
     private static final CoordinatorCompletionParticipantClient CLIENT = new CoordinatorCompletionParticipantClient() ;

    
The complete action.
 
     private String completeAction = null;
    
The close action.
 
     private String closeAction = null;
    
The cancel action.
 
     private String cancelAction = null;
    
The compensat action.
 
     private String compensateAction = null;
    
The faulted action.
 
     private String failedAction = null;
    
The exited action.
 
     private String exitedAction = null;
    
The not completed action.
 
     private String notCompletedAction = null;
    
The get status action.
 
     private String getStatusAction = null;
    
The status action.
 
     private String statusAction = null;

    
The coordinator completion coordinator URI for replies.
 
     private MAPEndpoint coordinatorCompletionCoordinator = null;

    
The coordinator completion coordinator URI for secure replies.
 
    private MAPEndpoint secureCoordinatorCompletionCoordinator = null;

    
Construct the participant completion coordinator client.
    {
        final MAPBuilder builder = MAPBuilderFactory.getInstance().getBuilderInstance();
        final String coordinatorCompletionCoordinatorURIString =
        final String secureCoordinatorCompletionCoordinatorURIString =
         = builder.newEndpoint(coordinatorCompletionCoordinatorURIString);
         = builder.newEndpoint(secureCoordinatorCompletionCoordinatorURIString);
    }

    
Send a complete request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendComplete(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFromFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType complete = new NotificationType();
        port.completeOperation(complete);
    }

    
Send a close request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendClose(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFromFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType close = new NotificationType();
        port.closeOperation(close);
    }

    
Send a cancel request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendCancel(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFromFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType cancel = new NotificationType();
        port.cancelOperation(cancel);
    }

    
Send a compensate request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendCompensate(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFromFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType compensate = new NotificationType();
        port.compensateOperation(compensate);
    }

    
Send a failed request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendFailed(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType failed = new NotificationType();
        port.failedOperation(failed);
    }

    
Send an exited request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendExited(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType exit = new NotificationType();
        port.exitedOperation(exit);
    }

    
Send an exited request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendNotCompleted(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType notCompleted = new NotificationType();
        port.notCompleted(notCompleted);
    }

    
Send a get status request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendGetStatus(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFromFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        NotificationType getStatus = new NotificationType();
        port.getStatusOperation(getStatus);
    }

    
Send a status request.

Parameters:
map addressing context initialised with to and message ID.
identifier The identifier of the initiator.
Throws:
com.arjuna.webservices.SoapFault For any errors.
java.io.IOException for any transport errors.
    public void sendStatus(W3CEndpointReference endpointfinal MAP mapfinal InstanceIdentifier identifier,
        final QName state)
        throws SoapFaultIOException
    {
        MAPEndpoint coordinator = getCoordinator(endpointmap);
        AddressingHelper.installFromFaultTo(mapcoordinatoridentifier);
        port = getPort(endpointmap);
        StatusType status = new StatusType();
        status.setState(state);
        port.statusOperation(status);
    }

    
send a soap fault

Parameters:
soapFault the fault to be sent
endpoint the endpoint to send the fault to
map addressing context to be used to send the fault
faultAction the action to associate with the message
    public void sendSoapFault(SoapFault11 soapFaultW3CEndpointReference endpoint, MAP mapString faultAction)
            throws SoapFaultIOException
    {
        AddressingHelper.installNoneReplyTo(map);
        map.setAction(faultAction);
        port = getPort(endpointmapfaultAction);
        Fault fault = ((SoapFault11)soapFault).toFault();
        port.soapFault(fault);
    }
    
return a coordinator endpoint appropriate to the type of participant

Parameters:
endpoint
Returns:
either the secure coordinator endpoint or the non-secure endpoint
    MAPEndpoint getCoordinator(W3CEndpointReference endpoint, MAP map)
    {
        String address;
        if (endpoint != null) {
            NativeEndpointReference nativeRef = EndpointHelper.transform(NativeEndpointReference.classendpoint);
            address = nativeRef.getAddress();
        } else {
            address = map.getTo();
        }
        if (address.startsWith("https")) {
            return ;
        } else {
            return ;
        }
    }

    
Get the Completion Coordinator client singleton.

Returns:
The Completion Coordinator client singleton.
    {
        return ;
    }

    
obtain a port from the participant endpoint configured with the instance identifier handler and the supplied addressing properties supplemented with the given action

Parameters:
participant
map
action
Returns:
    getPort(final W3CEndpointReference participantfinal MAP mapfinal String action)
    {
        AddressingHelper.installNoneReplyTo(map);
        if (participant != null) {
            return WSBAClient.getCoordinatorCompletionParticipantPort(participantactionmap);
        } else {
            return WSBAClient.getCoordinatorCompletionParticipantPort(actionmap);
        }
    }
New to GrepCode? Check out our FAQ X