Examples of CoordinationContextType

com.arjuna.webservices.wscoor.CoordinationContextType
Representation of the Coordination Context type. @author kevin
org.oasis_open.docs.ws_tx.wscoor._2006._06.CoordinationContextType
3.org/2001/XMLSchema}anyType"> <sequence> <element name="Identifier"> <complexType> <simpleContent> <extension base="<http://www.w3.org/2001/XMLSchema>anyURI"> </extension> </simpleContent> </complexType> </element> <element ref="{http://docs.oasis-open.org/ws-tx/wscoor/2006/06}Expires" minOccurs="0"/> <element name="CoordinationType" type="{http://www.w3.org/2001/XMLSchema}anyURI"/> <element name="RegistrationService" type="{http://www.w3.org/2005/08/addressing}EndpointReferenceType"/> </sequence> </restriction> </complexContent> </complexType>

Examples of com.arjuna.webservices.wscoor.CoordinationContextType

    public void testInvalidProtocolProtocolIdentifierException()
        throws Exception
    {
        final String messageId = "testInvalidProtocolProtocolIdentifierException" ;
        final String protocolIdentifier = TestUtil.INVALID_PROTOCOL_PROTOCOL_IDENTIFIER ;
        final CoordinationContextType coordinationContext = new CoordinationContextType() ;
        coordinationContext.setCoordinationType(new URI(TestUtil.COORDINATION_TYPE)) ;
        coordinationContext.setIdentifier(new AttributedURIType("identifier")) ;
        coordinationContext.setRegistrationService(registrationCoordinator) ;
        try
        {
            RegistrationCoordinator.register(coordinationContext, messageId, registrationRequester, protocolIdentifier) ;
        }
        catch (final InvalidProtocolException ipe) {}

View Full Code Here

Examples of com.arjuna.webservices.wscoor.CoordinationContextType

    public void testInvalidStateProtocolIdentifierException()
        throws Exception
    {
        final String messageId = "testInvalidStateProtocolIdentifierException" ;
        final String protocolIdentifier = TestUtil.INVALID_STATE_PROTOCOL_IDENTIFIER ;
        final CoordinationContextType coordinationContext = new CoordinationContextType() ;
        coordinationContext.setCoordinationType(new URI(TestUtil.COORDINATION_TYPE)) ;
        coordinationContext.setIdentifier(new AttributedURIType("identifier")) ;
        coordinationContext.setRegistrationService(registrationCoordinator) ;
        try
        {
            RegistrationCoordinator.register(coordinationContext, messageId, registrationRequester, protocolIdentifier) ;
        }
        catch (final InvalidStateException ise) {}

View Full Code Here

Examples of com.arjuna.webservices.wscoor.CoordinationContextType

    public void testNoActivityProtocolIdentifierException()
        throws Exception
    {
        final String messageId = "testNoActivityProtocolIdentifierException" ;
        final String protocolIdentifier = TestUtil.NO_ACTIVITY_PROTOCOL_IDENTIFIER ;
        final CoordinationContextType coordinationContext = new CoordinationContextType() ;
        coordinationContext.setCoordinationType(new URI(TestUtil.COORDINATION_TYPE)) ;
        coordinationContext.setIdentifier(new AttributedURIType("identifier")) ;
        coordinationContext.setRegistrationService(registrationCoordinator) ;
        try
        {
            RegistrationCoordinator.register(coordinationContext, messageId, registrationRequester, protocolIdentifier) ;
        }
        catch (final NoActivityException nae) {}

View Full Code Here

Examples of com.arjuna.webservices.wscoor.CoordinationContextType

    {
        final String messageID = "testKnownCoordinationType" ;
        final String coordinationTypeURI = TestUtil.COORDINATION_TYPE ;
        try
        {
            final CoordinationContextType coordinationContext = ActivationCoordinator.createCoordinationContext(activationCoordinatorURI, messageID, coordinationTypeURI, null, null) ;
            
            assertNotNull(coordinationContext);
            assertNotNull(coordinationContext.getCoordinationType()) ;
            assertEquals(TestUtil.COORDINATION_TYPE, coordinationContext.getCoordinationType().getValue());
            assertNotNull(coordinationContext.getRegistrationService()) ;
            assertNotNull(coordinationContext.getRegistrationService().getAddress()) ;
            assertNotNull(coordinationContext.getRegistrationService().getAddress().getValue()) ;
        }
        catch (final Throwable th)
        {
            fail("Unexpected exception: " + th);
        }

View Full Code Here

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

                    SCALogger.ROOT_LOGGER.ignoringReceivedTransactionContext();
                    return false;
                }
                
                ClassLoader origCl = Thread.currentThread().getContextClassLoader();
                CoordinationContextType cc = null;
                try {
                    Thread.currentThread().setContextClassLoader(SwitchYardRemotingServlet.class.getClassLoader());
                    cc = _txSerializer.deserialise(txContextHeader);
                } finally {
                    Thread.currentThread().setContextClassLoader(origCl);

View Full Code Here

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

            }
            txOutboundBridge.start();
            
            // embed WS-AT transaction context into request header 
            final com.arjuna.mw.wst11.TransactionManager wsatManager = TransactionManagerFactory.transactionManager();
            CoordinationContextType coordinationContext = null;
            if (wsatManager != null) {
                final TxContextImple txContext = (TxContextImple)wsatManager.currentTransaction();
                if (txContext != null) {
                    coordinationContext = txContext.context().getCoordinationContext();
                }

View Full Code Here

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

    public void completionCommit(final String coordinatorURI, final AddressingProperties addressingProperties)
        throws SoapFault11
    {
        try
        {
            final CoordinationContextType context = InteropUtil.createCoordinationContext(coordinatorURI) ;
            final CompletionCoordinatorParticipant participant = InteropUtil.registerCompletion(context, context.getIdentifier().getValue()) ;
            participant.commit() ;
        }
        catch (final Throwable th)
        {
            throw new SoapFault11(th) ;

View Full Code Here

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

    public void completionRollback(final String coordinatorURI, final AddressingProperties addressingProperties)
        throws SoapFault11
    {
        try
        {
            final CoordinationContextType context = InteropUtil.createCoordinationContext(coordinatorURI) ;
            final CompletionCoordinatorParticipant participant = InteropUtil.registerCompletion(context, context.getIdentifier().getValue()) ;
            participant.rollback() ;
        }
        catch (final Throwable th)
        {
            throw new SoapFault11(th) ;

View Full Code Here

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

    public void testAlreadyRegisteredProtocolIdentifierException()
        throws Exception
    {
        final String messageId = "testAlreadyRegisteredProtocolIdentifierException" ;
        final String protocolIdentifier = TestUtil.ALREADY_REGISTERED_PROTOCOL_IDENTIFIER ;
        final CoordinationContextType coordinationContext = new CoordinationContextType() ;
        final CoordinationContextType.Identifier identifierInstance = new CoordinationContextType.Identifier();
        coordinationContext.setCoordinationType(TestUtil.COORDINATION_TYPE) ;
        coordinationContext.setIdentifier(identifierInstance);
        identifierInstance.setValue("identifier") ;
        coordinationContext.setRegistrationService(TestUtil11.getRegistrationEndpoint(identifierInstance.getValue())) ;
        W3CEndpointReference participantEndpoint = TestUtil11.getProtocolParticipantEndpoint("participant");
        try
        {
            RegistrationCoordinator.register(coordinationContext, messageId, participantEndpoint, protocolIdentifier) ;
        }

View Full Code Here

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

    public void testInvalidProtocolProtocolIdentifierException()
        throws Exception
    {
        final String messageId = "testInvalidProtocolProtocolIdentifierException" ;
        final String protocolIdentifier = TestUtil.INVALID_PROTOCOL_PROTOCOL_IDENTIFIER ;
        final CoordinationContextType coordinationContext = new CoordinationContextType() ;
        final CoordinationContextType.Identifier identifierInstance = new CoordinationContextType.Identifier();
        coordinationContext.setCoordinationType(TestUtil.COORDINATION_TYPE) ;
        coordinationContext.setIdentifier(identifierInstance);
        identifierInstance.setValue("identifier") ;
        coordinationContext.setRegistrationService(TestUtil11.getRegistrationEndpoint(identifierInstance.getValue())) ;
        W3CEndpointReference participantEndpoint = TestUtil11.getProtocolParticipantEndpoint("participant");
        try
        {
            RegistrationCoordinator.register(coordinationContext, messageId, participantEndpoint, protocolIdentifier) ;
        }

View Full Code Here

0 1 2 3 4 5

TOP

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.