Package com.arjuna.wsc11

Examples of com.arjuna.wsc11.ContextFactory


        CreateCoordinationContextResponseType createCoordinationContextResponseType;

        createCoordinationContextResponseType =
                ActivationCoordinatorClient.getClient().sendCreateCoordination(addressingProperties, coordinationType, expiresInstance, coordinationContext) ;

        final CreateCoordinationContextDetails details = testActivationCoordinatorProcessor.getCreateCoordinationContextDetails(messageId, 10000) ;
        final CreateCoordinationContextType requestCreateCoordinationContext = details.getCreateCoordinationContext() ;
        final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;

        assertNotNull(requestAddressingProperties.getTo());
        assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.activationCoordinatorService);
        // we don't care about the reply to field --  this is an RPC style message
        // assertNotNull(requestAddressingProperties.getReplyTo());
View Full Code Here


        final String coordinationType = TestUtil.COORDINATION_TYPE ;
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(TestUtil11.activationCoordinatorService, messageId) ;
        CreateCoordinationContextResponseType response =
                ActivationCoordinatorClient.getClient().sendCreateCoordination(addressingProperties, coordinationType, null, null) ;

        final CreateCoordinationContextDetails details = testActivationCoordinatorProcessor.getCreateCoordinationContextDetails(messageId, 10000) ;
        final CreateCoordinationContextType requestCreateCoordinationContext = details.getCreateCoordinationContext() ;
        final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;

        assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.activationCoordinatorService);
        assertEquals(requestAddressingProperties.getMessageID().getURI().toString(), messageId);

        assertNull(requestCreateCoordinationContext.getExpires()) ;
View Full Code Here

    {
        final String coordinationType = TestUtil.INVALID_CREATE_PARAMETERS_COORDINATION_TYPE;
        try {
            ActivationCoordinator.createCoordinationContext(TestUtil11.activationCoordinatorService, messageId, coordinationType, null, null) ;
        } catch (InvalidCreateParametersException icpe) {
            final CreateCoordinationContextDetails details = testActivationCoordinatorProcessor.getCreateCoordinationContextDetails(messageId, 10000) ;
            final CreateCoordinationContextType requestCreateCoordinationContext = details.getCreateCoordinationContext() ;
            final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;
            assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.activationCoordinatorService);
            assertEquals(requestAddressingProperties.getMessageID().getURI().toString(), messageId);

            assertNull(requestCreateCoordinationContext.getExpires()) ;
            assertNull(requestCreateCoordinationContext.getCurrentContext()) ;
View Full Code Here

        registerType.setProtocolIdentifier(protocolIdentifier);
        registerType.setParticipantProtocolService(participantProtocolEndpoint);
        RegistrationPortType port = WSCOORClient.getRegistrationPort(registerEndpoint, CoordinationConstants.WSCOOR_ACTION_REGISTER, messageId);
        response = port.registerOperation(registerType);

        final RegisterDetails details = testRegistrationCoordinatorProcessor.getRegisterDetails(messageId, 10000) ;
        final RegisterType requestRegister = details.getRegister() ;
        final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;
        final ArjunaContext requestArjunaContext = details.getArjunaContext() ;

        assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.registrationCoordinatorService);
        assertEquals(requestAddressingProperties.getMessageID().getURI().toString(), messageId);

        if (instanceIdentifier == null)
View Full Code Here

        identifierInstance.setValue("identifier");
        coordinationContext.setRegistrationService(TestUtil11.getRegistrationEndpoint(identifierInstance.getValue())) ;

        W3CEndpointReference coordinator = RegistrationCoordinator.register(coordinationContext, messageId, participantProtocolService, protocolIdentifier) ;

        final RegisterDetails details = testRegistrationCoordinatorProcessor.getRegisterDetails(messageId, 10000) ;
        final RegisterType requestRegister = details.getRegister() ;
        final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;
        final ArjunaContext requestArjunaContext = details.getArjunaContext() ;

        assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.registrationCoordinatorService);
        assertEquals(requestAddressingProperties.getMessageID().getURI().toString(), messageId);

        assertNotNull(requestArjunaContext) ;
View Full Code Here

                    fail("expected cannot register exception");
                }
                break;
        }

        final RegisterDetails details = testRegistrationCoordinatorProcessor.getRegisterDetails(messageId, 10000) ;
        final RegisterType requestRegister = details.getRegister() ;
        final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;
        final ArjunaContext requestArjunaContext = details.getArjunaContext() ;

        assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.registrationCoordinatorService);
        assertEquals(requestAddressingProperties.getMessageID().getURI().toString(), messageId);

        assertNotNull(requestArjunaContext) ;
View Full Code Here

        identifierInstance.setValue("identifier");
        coordinationContext.setRegistrationService(TestUtil11.getRegistrationEndpoint(identifierInstance.getValue())) ;

        W3CEndpointReference coordinator = RegistrationCoordinator.register(coordinationContext, messageId, participantProtocolService, protocolIdentifier) ;

        final RegisterDetails details = testRegistrationCoordinatorProcessor.getRegisterDetails(messageId, 10000) ;
        final RegisterType requestRegister = details.getRegister() ;
        final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;
        final ArjunaContext requestArjunaContext = details.getArjunaContext() ;

        assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.registrationCoordinatorService);
        assertEquals(requestAddressingProperties.getMessageID().getURI().toString(), messageId);

        assertNotNull(requestArjunaContext) ;
View Full Code Here

                    fail("expected already registered exception");
                }
                break;
        }

        final RegisterDetails details = testRegistrationCoordinatorProcessor.getRegisterDetails(messageId, 10000) ;
        final RegisterType requestRegister = details.getRegister() ;
        final AddressingProperties requestAddressingProperties = details.getAddressingProperties() ;
        final ArjunaContext requestArjunaContext = details.getArjunaContext() ;

        assertEquals(requestAddressingProperties.getTo().getURI().toString(), TestUtil11.registrationCoordinatorService);
        assertEquals(requestAddressingProperties.getMessageID().getURI().toString(), messageId);

        assertNotNull(requestArjunaContext) ;
View Full Code Here

TOP

Related Classes of com.arjuna.wsc11.ContextFactory

Copyright © 2018 www.massapicom. 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.