Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2011 Red Hat, Inc, and individual contributors.
   *
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *   http://www.apache.org/licenses/LICENSE-2.0
   *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 
 package org.projectodd.stilts.conduit.xa;
 
 
 
 
     private static Logger log = Logger.getLogger(PseudoXATransaction.class);
 
     PseudoXATransaction() {
     }
 
     void setRollbackOnly(boolean rollbackOnly) {
         this. = rollbackOnly;
     }
 
     boolean isRollbackOnly() {
         return this.;
     }
 
     boolean isReadOnly() {
         return (this..isEmpty() && this..isEmpty() && this..isEmpty() );
     }
 
     void addSentMessage(StompMessage message) {
         this..addmessage );
     }
 
     boolean hasSentMessages() {
         return ! this..isEmpty();
     }
 
     void addAck(Acknowledger acknowledger) {
         this..add(  acknowledger );
     }
 
     boolean hasAcks() {
         return ! this..isEmpty();
     }
 
     void addNack(Acknowledger acknowledger) {
         this..add(acknowledger);
     }
 
     boolean hasNacks() {
         return ! this..isEmpty();
     }
 
     public void commit(MessageConduit conduit) {
         for (StompMessage each :  ) {
             try {
                 conduit.sendeach );
             } catch (Exception e) {
                 .errorf(e"Cannot send message: %s"each);
             }
         }
 
         .clear();
 
         for ( Acknowledger each : this. ) {
             try {
                 each.ack();
             } catch (Exception e) {
                 .errorf(e"Cannot ack: %s"each);
             }
         }
 
         this..clear();
 
         for ( Acknowledger each : this. ) {
             try {
                 each.nack();
             } catch (Exception e) {
                 .errorf(e"Cannot nack: %s"each);
             }
         }
 
         this..clear();
     }
    public void rollback(MessageConduit messageConduit) {
        .clear();
        .clear();
    }
    private boolean rollbackOnly;
New to GrepCode? Check out our FAQ X