Examples of CreateCoordinationContextResponseType


Examples of com.arjuna.webservices.wscoor.CreateCoordinationContextResponseType

        else if (!callback.hasTriggered())
        {
            throw new SoapFault10(SoapFaultType.FAULT_RECEIVER, null, WSCLogger.log_mesg.getString("com.arjuna.wsc.ActivationCoordinator_2")) ;
        }
       
        final CreateCoordinationContextResponseType response = callback.getCreateCoordinationContextResponse() ;
        if (response != null)
        {
            return response.getCoordinationContext() ;
        }
        final SoapFault soapFault = callback.getSoapFault() ;
        if (CoordinationConstants.WSCOOR_ERROR_CODE_INVALID_PARAMETERS_QNAME.equals(soapFault.getSubcode()))
        {
            throw new InvalidCreateParametersException(soapFault.getReason()) ;
View Full Code Here

Examples of com.arjuna.webservices.wscoor.CreateCoordinationContextResponseType

     */
    public SoapBody invoke(final SoapDetails soapDetails, final MessageContext context,
        final MessageContext responseContext, final String action, final XMLStreamReader in)
        throws XMLStreamException, SoapFault
    {
        final CreateCoordinationContextResponseType createCoordinationContextResponse = new CreateCoordinationContextResponseType(in) ;
        final AddressingContext addressingContext = AddressingContext.getContext(context) ;
        TaskManager.getManager().queueTask(new Task() {
            public void executeTask() {
                ActivationRequesterProcessor.getRequester().handleCreateCoordinationContextResponse(createCoordinationContextResponse, addressingContext) ;
            }
View Full Code Here

Examples of com.arjuna.webservices.wscoor.CreateCoordinationContextResponseType

     * @throws IOException for any transport errors.
     */
    public void sendCreateCoordinationResponse(final AddressingContext addressingContext, final CoordinationContextType coordinationContext)
        throws SoapFault, IOException
    {
        final CreateCoordinationContextResponseType response = new CreateCoordinationContextResponseType() ;
        response.setCoordinationContext(coordinationContext) ;
       
        sendOneWay(response, addressingContext, soapService, activationCoordinator, null,
            CoordinationConstants.WSCOOR_ELEMENT_CREATE_COORDINATION_CONTEXT_RESPONSE_QNAME,
            createCoordinationContextResponseAction) ;
    }
View Full Code Here

Examples of com.arjuna.webservices.wscoor.CreateCoordinationContextResponseType

     */
    public SoapBody invoke(final SoapDetails soapDetails, final MessageContext context,
        final MessageContext responseContext, final String action, final XMLStreamReader in)
        throws XMLStreamException, SoapFault
    {
        final CreateCoordinationContextResponseType createCoordinationContextResponse = new CreateCoordinationContextResponseType(in) ;
        final AddressingContext addressingContext = AddressingContext.getContext(context) ;
        TaskManager.getManager().queueTask(new Task() {
            public void executeTask() {
                ActivationRequesterProcessor.getRequester().handleCreateCoordinationContextResponse(createCoordinationContextResponse, addressingContext) ;
            }
View Full Code Here

Examples of com.arjuna.webservices.wscoor.CreateCoordinationContextResponseType

     * @throws IOException for any transport errors.
     */
    public void sendCreateCoordinationResponse(final AddressingContext addressingContext, final CoordinationContextType coordinationContext)
        throws SoapFault, IOException
    {
        final CreateCoordinationContextResponseType response = new CreateCoordinationContextResponseType() ;
        response.setCoordinationContext(coordinationContext) ;
       
        sendOneWay(response, addressingContext, soapService, activationCoordinator, null,
            CoordinationConstants.WSCOOR_ELEMENT_CREATE_COORDINATION_CONTEXT_RESPONSE_QNAME,
            createCoordinationContextResponseAction) ;
    }
View Full Code Here

Examples of com.arjuna.webservices.wscoor.CreateCoordinationContextResponseType

        else if (!callback.hasTriggered())
        {
            throw new SoapFault(SoapFaultType.FAULT_RECEIVER, null, WSCLogger.log_mesg.getString("com.arjuna.wsc.ActivationCoordinator_2")) ;
        }
       
        final CreateCoordinationContextResponseType response = callback.getCreateCoordinationContextResponse() ;
        if (response != null)
        {
            return response.getCoordinationContext() ;
        }
        final SoapFault soapFault = callback.getSoapFault() ;
        if (CoordinationConstants.WSCOOR_ERROR_CODE_INVALID_PARAMETERS_QNAME.equals(soapFault.getSubcode()))
        {
            throw new InvalidCreateParametersException(soapFault.getReason()) ;
View Full Code Here

Examples of org.oasis_open.docs.ws_tx.wscoor._2006._06.CreateCoordinationContextResponseType

            expiresValue.setValue(expires.longValue());
        }

        try
        {
            CreateCoordinationContextResponseType response;
            ActivationCoordinatorClient client = ActivationCoordinatorClient.getClient();
            response = client.sendCreateCoordination(addressingProperties, coordinationTypeURI, expiresValue, currentContext) ;
            return response.getCoordinationContext();
        }
        catch (final IOException ioe)
        {
            throw new SoapFault11(ioe) ;
        } catch (SOAPFaultException sfe) {
View Full Code Here

Examples of org.oasis_open.docs.ws_tx.wscoor._2006._06.CreateCoordinationContextResponseType

            }
        }
       
        // we have to return a value so lets cook one up

        CreateCoordinationContextResponseType createCoordinationContextResponseType = new CreateCoordinationContextResponseType();
        CoordinationContext coordinationContext = new CoordinationContext();
        coordinationContext.setCoordinationType(coordinationType);
        coordinationContext.setExpires(createCoordinationContext.getExpires());
        String identifier = nextIdentifier();
        CoordinationContextType.Identifier identifierInstance = new CoordinationContextType.Identifier();
        identifierInstance.setValue(identifier);
        coordinationContext.setIdentifier(identifierInstance);
        W3CEndpointReferenceBuilder builder = new W3CEndpointReferenceBuilder();
        builder.serviceName(CoordinationConstants.REGISTRATION_SERVICE_QNAME);
        builder.endpointName(CoordinationConstants.REGISTRATION_ENDPOINT_QNAME);
        builder.address(TestUtil.PROTOCOL_COORDINATOR_SERVICE);
        W3CEndpointReference registrationService = builder.build();
        coordinationContext.setRegistrationService(TestUtil11.getRegistrationEndpoint(identifier));
        createCoordinationContextResponseType.setCoordinationContext(coordinationContext);

        return createCoordinationContextResponseType;
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.