Package org.omg.CosTransactions

Examples of org.omg.CosTransactions.PropagationContext

67
68
69
70
71
72
73
74
75
76
77
            //19.6.2.1 (1) propagate an "empty" transaction context.
            //but, it needs an xid!
            TransIdentity transIdentity = new TransIdentity(null, null, NULL_XID);
            int timeout = 0;
            Any implementationSpecificData = Util.getORB().create_any();
            PropagationContext propagationContext = new PropagationContext(timeout, transIdentity, NO_PARENTS, implementationSpecificData);
            Codec codec = Util.getCodec();
            Any any = Util.getORB().create_any();
            PropagationContextHelper.insert(any, propagationContext);
            byte[] encodedPropagationContext;
            try {
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        {
            org.omg.PortableInterceptor.Current pi_current =
                (org.omg.PortableInterceptor.Current)
    orb.resolve_initial_references("PICurrent");

            PropagationContext context = PropagationContextHelper.extract
                (pi_current.get_slot(slot_id));

            Control control = ControlHelper.extract(context.implementation_specific_data);
            ts_current.resume(control);
        }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
        try
        {
            org.omg.PortableInterceptor.Current pi_current =
                (org.omg.PortableInterceptor.Current)orb.resolve_initial_references("PICurrent");

            PropagationContext context = PropagationContextHelper.extract
                (pi_current.get_slot(slot_id));

            return ControlHelper.extract(context.implementation_specific_data);
        }
        catch(Exception e)
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
                                                 new otid_t(0, 0, new byte[0]));
     
            Any control_any = orb.create_any();
            ControlHelper.insert(control_any, control);

            PropagationContext context = new PropagationContext(timeout,
                                                                id, new TransIdentity[0],
                                                                control_any);
            Any context_any = orb.create_any();
            PropagationContextHelper.insert(context_any, context);
View Full Code Here
348
349
350
351
352
353
354
355
356
357
358
359
            int timeout =
                (timeouts.containsKey(thread))?
                ((Integer) timeouts.get(thread)).intValue() :
                DEFAULT_TIMEOUT;

            PropagationContext context =
                new PropagationContext(timeout,
                                       id,
                                       new TransIdentity[0],
                                       control_any);

            Any context_any = orb.create_any();
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
  
   protected Any getTransactionPropagationContextAny()
   {
      try
      {
         PropagationContext pc = null;
         TransactionManager tm = getTransactionManager();
         Transaction tx = tm.getTransaction();
         if (!TxUtils.isUncommitted(tx))
         {
            if (traceEnabled)
View Full Code Here
195
196
197
198
199
200
201
202
203
204
205
        if (theControl != null)
        {
      try
      {
          Coordinator theCoordinator = theControl.get_coordinator();
          PropagationContext ctx = null;

          if (theCoordinator != null)
          {
        ctx = theCoordinator.get_txcontext();
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
        if (theControl != null)
        {
      try
      {
          Coordinator theCoordinator = theControl.get_coordinator();
          PropagationContext ctx = null;
       
          if (theCoordinator != null)
          {
        ctx = theCoordinator.get_txcontext();
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
        if (theControl != null)
        {
      try
      {
          Coordinator theCoordinator = theControl.get_coordinator();
          PropagationContext ctx = null;
       
          if (theCoordinator != null)
          {
        ctx = theCoordinator.get_txcontext();
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        {
            org.omg.PortableInterceptor.Current pi_current =
                (org.omg.PortableInterceptor.Current)
    orb.resolve_initial_references("PICurrent");

            PropagationContext context = PropagationContextHelper.extract
                (pi_current.get_slot(slot_id));

            Control control = ControlHelper.extract(context.implementation_specific_data);
            ts_current.resume(control);
        }
View Full Code Here
TOP

Related Classes of org.omg.CosTransactions.PropagationContext

  • com.arjuna.ats.jts.orbspecific.hporb.interceptors.interposition.InterpositionClientRequestInterceptorImpl
  • com.arjuna.ats.jts.orbspecific.jacorb.interceptors.interposition.InterpositionClientRequestInterceptorImpl
  • com.arjuna.ats.jts.orbspecific.javaidl.interceptors.interposition.InterpositionClientRequestInterceptorImpl
  • org.apache.geronimo.corba.transaction.AbstractServerTransactionPolicyConfig
  • org.apache.geronimo.corba.transaction.nodistributedtransactions.NoDTxClientTransactionPolicyConfig
  • org.jacorb.transaction.ServerContextTransferInterceptor
  • org.jacorb.transaction.TransactionCurrentImpl
  • org.jboss.tm.iiop._CoordinatorExtStub
  • org.jboss.tm.iiop._TransactionServiceStub
  • org.jboss.tm.iiop.TransactionFactoryExtPOA
    • 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.