Examples of org.jboss.jms.tx.TransactionRequest

org.jboss.jms.tx.TransactionRequest
This class contains all the data needed to perform a JMS transaction. @author Tim FoxPartially based on JBossMQ version by: @author Tim Fox @author Hiram Chirino @author David Maplesden @author Adrian Brock @author Daniel Bloomfield Ramagem @author Ovidiu Feodorov @version $Revision: 2202 $$Id: TransactionRequest.java 2202 2007-02-08 10:50:26Z timfox $

      
      public void testConnectionSendTransactionRequest() throws Exception
      {
         ClientTransaction tx = new ClientTransaction();
         
         TransactionRequest tr = new TransactionRequest(TransactionRequest.ONE_PHASE_COMMIT_REQUEST, null, tx);
         
         RequestSupport req =
            new ConnectionSendTransactionRequest("23", (byte)77, tr, false);
                 
         testPacket(req, PacketSupport.REQ_CONNECTION_SENDTRANSACTION);

View Full Code Here


   public void read(DataInputStream is) throws Exception
   {
      super.read(is);
      
      req = new TransactionRequest();


      final boolean supportsRecovered = ConnectionCapabilities.doesConnectionSupportRecoveryRollback(version) ;
      req.setSupportsRecovered(supportsRecovered) ;
      
      req.read(is);

View Full Code Here

      ConnectionAdvised del = (ConnectionAdvised)invocation.getTargetObject();
      ServerConnectionEndpoint ce = (ServerConnectionEndpoint)del.getEndpoint();


      MethodInvocation mi = (MethodInvocation)invocation;


      TransactionRequest t = (TransactionRequest)mi.getArguments()[0];


      ClientTransaction txState = t.getState();


      if (txState != null)
      {
         // distinct list of destinations...
         HashSet destinations = new HashSet();

View Full Code Here

      ConnectionAdvised del = (ConnectionAdvised)invocation.getTargetObject();
      ServerConnectionEndpoint ce = (ServerConnectionEndpoint)del.getEndpoint();


      MethodInvocation mi = (MethodInvocation)invocation;


      TransactionRequest t = (TransactionRequest)mi.getArguments()[0];


      ClientTransaction txState = t.getState();


      if (txState != null)
      {
         // distinct list of destinations...
         HashSet destinations = new HashSet();

View Full Code Here

/* 164 */     ConnectionAdvised del = (ConnectionAdvised)invocation.getTargetObject();
/* 165 */     ServerConnectionEndpoint ce = (ServerConnectionEndpoint)del.getEndpoint();
/*     */ 
/* 167 */     MethodInvocation mi = (MethodInvocation)invocation;
/*     */ 
/* 169 */     TransactionRequest t = (TransactionRequest)mi.getArguments()[0];
/*     */ 
/* 171 */     ClientTransaction txState = t.getState();
/*     */     Iterator iterDestinations;
/* 173 */     if (txState != null)
/*     */     {
/* 176 */       HashSet destinations = new HashSet();
/*     */

View Full Code Here

/*    */ 
/*    */   public void read(DataInputStream is) throws Exception
/*    */   {
/* 63 */     super.read(is);
/*    */ 
/* 65 */     this.req = new TransactionRequest();
/*    */ 
/* 67 */     this.req.read(is);
/*    */ 
/* 69 */     this.checkForDuplicates = is.readBoolean();
/*    */   }

View Full Code Here

      
      public void testConnectionSendTransactionRequest() throws Exception
      {
         ClientTransaction tx = new ClientTransaction();
         
         TransactionRequest tr = new TransactionRequest(TransactionRequest.ONE_PHASE_COMMIT_REQUEST, null, tx);
         
         RequestSupport req =
            new ConnectionSendTransactionRequest("23", (byte)77, tr, false);
                 
         testPacket(req, PacketSupport.REQ_CONNECTION_SENDTRANSACTION);

View Full Code Here

0 1

TOP

Related Classes of org.jboss.jms.tx.TransactionRequest

org.jboss.jms.server.container.SecurityAspect

org.jboss.jms.wireformat.ConnectionSendTransactionRequest

org.jboss.messaging.core.tx.MessagingXid

org.jboss.test.messaging.jms.WireFormatTest$TestWireFormat

org.jboss.test.messaging.tools.aop.PoisonInterceptor

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.