Package javax.transaction.xa

Examples of javax.transaction.xa.XAResource.start()

2928
2929
2930
2931
2932
2933
2934
2935
2936
2937
2938
         prod1.send(tm1);
  
         res1.end(xid1, XAResource.TMSUCCESS);
  
  
         res2.start(xid2, XAResource.TMNOFLAGS);
  
         MessageProducer prod2 = sess2.createProducer(queue);
  
         TextMessage tm2 = sess2.createTextMessage("testing2");
  
View Full Code Here
3069
3070
3071
3072
3073
3074
3075
3076
3077
3078
3079
         prod1.send(tm1);
  
         res1.end(xid1, XAResource.TMSUCCESS);
  
  
         res2.start(xid2, XAResource.TMNOFLAGS);
  
         MessageProducer prod2 = sess2.createProducer(queue);
  
         TextMessage tm2 = sess2.createTextMessage("testing2");
  
View Full Code Here
3214
3215
3216
3217
3218
3219
3220
3221
3222
3223
3224
         prod2.send(tm2);
  
         res1.end(xid1, XAResource.TMSUCCESS);
  
  
         res2.start(xid2, XAResource.TMNOFLAGS);
  
         MessageProducer prod3 = sess2.createProducer(queue);
  
         TextMessage tm3 = sess2.createTextMessage("testing3");
  
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
           
            xid1 = new MessagingXid("blah1".getBytes(), 42, "blahblah1".getBytes());
                    
            TextMessage tm = sess.createTextMessage("message1");
           
            res.start(xid1, XAResource.TMNOFLAGS);
           
            prod.send(tm);
           
            res.end(xid1, XAResource.TMSUCCESS);
           
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275
           
            xid2 = new MessagingXid("blah2".getBytes(), 42, "blahblah2".getBytes());
                    
            TextMessage tm = sess.createTextMessage("message1");
           
            res.start(xid2, XAResource.TMNOFLAGS);
           
            prod.send(tm);
           
            res.end(xid2, XAResource.TMSUCCESS);
           
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
         Message message = session.createTextMessage();

         // Add the xa resource to xid1
         MyXid xid1 = new MyXid();
         XAResource resource = xaSession.getXAResource();
         resource.start(xid1, XAResource.TMNOFLAGS);

         // Do some work
         publisher.publish(message);

         // Suspend the transaction
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
         // Suspend the transaction
         resource.end(xid1, XAResource.TMSUSPEND);

         // Add the xa resource to xid2
         MyXid xid2 = new MyXid();
         resource.start(xid2, XAResource.TMNOFLAGS);

         // Do some work in the new transaction
         publisher.publish(message);

         // Commit the first transaction and end the branch
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
         XATopicSession xaSession = connection.createXATopicSession();

         // Add the xa resource to xid1
         MyXid xid1 = new MyXid();
         XAResource resource = xaSession.getXAResource();
         resource.start(xid1, XAResource.TMNOFLAGS);

         TopicSession session = xaSession.getTopicSession();
         TopicSubscriber subscriber = session.createSubscriber(topic);
         connection.start();
         TopicPublisher publisher = session.createPublisher(topic);
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
         // doing something differently on the transaction isolation.
         // Because of that this commit is necessary to complete this testcase.
         resource.commit(xid1, false);

         xid1 = new MyXid();
         resource.start(xid1, XAResource.TMNOFLAGS);

         // Receive the message
         message = subscriber.receive(1000);
         if (message == null)
            fail("No message?");
View Full Code Here
1385
1386
1387
1388
1389
1390
1391
1392
1393
1394
1395
         byte[] globalTxId = new byte[] { 6, 5, 4, 3, 2, 1, 0, 0, 0, 0 };

         Xid trailing = new MessagingXid(branchQualifier, 12435, globalTxId);

         res1.start(trailing, XAResource.TMNOFLAGS);

         MessageProducer prod1 = sess1.createProducer(queue1);

         TextMessage tm1 = sess1.createTextMessage("testing1");
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.