Package org.oasis_open.docs.ws_tx.wscoor._2006._06

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

486
487
488
489
490
491
492
493
494
495
496
497
498
499
        final InteropWaitState state = new InteropWaitState(AtomicTransactionConstants.WSAT_ACTION_COMMITTED) ;
        ProxyConversation.setConversationState(conversationId, state) ;
        try
        {
            final String serviceURI = ProxyURIRewriting.rewriteURI(conversationId, getParticipantURI()) ;
            final CoordinationContextType context = InteropUtil.createCoordinationContext(getSourceCoordinatorURI()) ;
            getParticipantStub().lostCommitted(serviceURI, context) ;
           
            final CompletionCoordinatorParticipant participant = InteropUtil.registerCompletion(context, context.getIdentifier().getValue()) ;
            participant.commit() ;
           
            state.waitForCompletion(0) ;
        }
        finally
View Full Code Here
279
280
281
282
283
284
285
286
287
288
289
    {
        try
        {
            final Long expires = (timeout > 0 ? new Long(timeout) : null) ;
            final String messageId = MessageId.getMessageId() ;
            final CoordinationContextType coordinationContext = ActivationCoordinator.createCoordinationContext(
                    _activationCoordinatorService, messageId, BusinessActivityConstants.WSBA_PROTOCOL_ATOMIC_OUTCOME, expires, null) ;
            if (coordinationContext == null)
            {
                throw new SystemException(
                    wstxLogger.log_mesg.getString("com.arjuna.mwlabs.wst11.ba.remote.UserBusinessActivityImple_2"));
View Full Code Here
305
306
307
308
309
310
311
312
313
314
315
  }

    private W3CEndpointReference getTerminationCoordinator(final TxContextImple ctx)
        throws SystemException
    {
        final CoordinationContextType coordinationContext = ctx.context().getCoordinationContext() ;
        final String messageId = MessageId.getMessageId() ;
        try
        {
            return RegistrationCoordinator.register(coordinationContext, messageId,
                getParticipantProtocolService(ctx.identifier(), ctx.isSecure()), com.arjuna.webservices.wsarjtx.ArjunaTXConstants.WSARJTX_PROTOCOL_TERMINATION) ;
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
107
  }

    public boolean isSecure()
    {
        if (valid()) {
            CoordinationContextType coordinationContextType = _context.getCoordinationContext();
            W3CEndpointReference epref = coordinationContextType.getRegistrationService();
            NativeEndpointReference nativeRef = EndpointHelper.transform(NativeEndpointReference.class, epref);
            String address = nativeRef.getAddress();
            return address.startsWith("https");
        }
        return false;
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
242
243
244
     * @param current the current AT context implememtation
     * @return an instance of the coordination context extension type
     */
    private CoordinationContext getContext(TxContextImple current)
    {
        CoordinationContextType contextType = getContextType(current);
        CoordinationContext context = new CoordinationContext();
        context.setCoordinationType(contextType.getCoordinationType());
        context.setExpires(contextType.getExpires());
        context.setIdentifier(contextType.getIdentifier());
        context.setRegistrationService(contextType.getRegistrationService());

        return context;
    }
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275

            final Long expires = (timeout > 0 ? new Long(timeout) : null) ;
            final String messageId = MessageId.getMessageId() ;
            final CoordinationContext currentContext = (current != null ? getContext(current) : null);
            final CoordinationContextType coordinationContext = ActivationCoordinator.createCoordinationContext(
                    _activationCoordinatorService, messageId, AtomicTransactionConstants.WSAT_PROTOCOL, expires, currentContext) ;
            if (coordinationContext == null)
            {
                throw new SystemException(
                    wstxLogger.log_mesg.getString("com.arjuna.mwlabs.wst.at.remote.UserTransaction11Imple__2"));
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
      currentTx = (TxContextImple) _ctxManager.suspend();

      if (currentTx == null)
        throw new CannotRegisterException();

            final CoordinationContextType coordinationContext = currentTx.context().getCoordinationContext() ;
            final String messageId = MessageId.getMessageId() ;

            return com.arjuna.wsc11.RegistrationCoordinator.register(coordinationContext, messageId, participant, protocol) ;
        }
    catch (final SoapFault sf)
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
            Unmarshaller unmarshaller;
            unmarshaller = jaxbContext.createUnmarshaller();
            // the header element is a valid CoordinationContextType node so we can unpack it directly
            // using JAXB. n.b. we will see a mustUnderstand=1 in the otherAttributes which we probably don't
            // want but it will do no harm.
            CoordinationContextType coordinationContextType = unmarshaller.unmarshal(headerElement, CoordinationContextType.class).getValue();

            return coordinationContextType;
        } catch (JAXBException jaxbe) {
            return null;
        }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
            else
            {
                baContext = null ;
            }

            final CoordinationContextType coordinationContext ;
            if (atContext != null)
            {
                coordinationContext = atContext.getCoordinationContext() ;
            }
            else if (baContext != null)
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
160
161
162
                final SOAPEnvelope soapEnvelope = soapMessage.getSOAPPart().getEnvelope() ;
                final SOAPHeaderElement soapHeaderElement = getHeaderElement(soapEnvelope, CoordinationConstants.WSCOOR_NAMESPACE, CoordinationConstants.WSCOOR_ELEMENT_COORDINATION_CONTEXT) ;

                if (soapHeaderElement != null)
                {
                    final CoordinationContextType cc = CoordinationContextHelper.deserialise(soapHeaderElement) ;
                    if (cc != null)
                    {
                        final String coordinationType = cc.getCoordinationType() ;
                        if (AtomicTransactionConstants.WSAT_PROTOCOL.equals(coordinationType))
                        {
                            final TxContext txContext = new TxContextImple(cc) ;
                            TransactionManagerFactory.transactionManager().resume(txContext) ;
                        }
View Full Code Here
TOP

Related Classes of org.oasis_open.docs.ws_tx.wscoor._2006._06.CoordinationContextType

  • com.arjuna.mw.wst11.client.JaxBaseHeaderContextProcessor
  • com.arjuna.mw.wst11.common.CoordinationContextHelper
  • com.arjuna.mw.wst11.service.JaxBaseHeaderContextProcessor
  • com.arjuna.mwlabs.wst11.at.context.TxContextImple
  • com.arjuna.mwlabs.wst11.at.ContextFactoryImple
  • com.arjuna.mwlabs.wst11.at.remote.TransactionManagerImple
  • com.arjuna.mwlabs.wst11.at.remote.UserTransactionImple
  • com.arjuna.mwlabs.wst11.at.SubordinateImporter
  • com.arjuna.mwlabs.wst11.ba.context.TxContextImple
  • com.arjuna.mwlabs.wst11.ba.ContextFactoryImple
    • 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.