001 /**
002 * Licensed to the Apache Software Foundation (ASF) under one or more
003 * contributor license agreements. See the NOTICE file distributed with
004 * this work for additional information regarding copyright ownership.
005 * The ASF licenses this file to You under the Apache License, Version 2.0
006 * (the "License"); you may not use this file except in compliance with
007 * the License. You may obtain a copy of the License at
008 *
009 * http://www.apache.org/licenses/LICENSE-2.0
010 *
011 * Unless required by applicable law or agreed to in writing, software
012 * distributed under the License is distributed on an "AS IS" BASIS,
013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
014 * See the License for the specific language governing permissions and
015 * limitations under the License.
016 */
017 package org.apache.camel.processor;
018
019 import org.apache.camel.Exchange;
020 import org.apache.camel.Processor;
021 import org.apache.camel.RollbackExchangeException;
022
023 /**
024 * Processor for marking an {@link org.apache.camel.Exchange} to rollback.
025 *
026 * @version $Revision: 792504 $
027 */
028 public class RollbackProcessor implements Processor, Traceable {
029
030 private String message;
031
032 public RollbackProcessor() {
033 }
034
035 public RollbackProcessor(String message) {
036 this.message = message;
037 }
038
039 public void process(Exchange exchange) throws Exception {
040 // mark the exchange for rollback
041 exchange.setProperty(Exchange.ROLLBACK_ONLY, Boolean.TRUE);
042 if (message != null) {
043 exchange.setException(new RollbackExchangeException(message, exchange));
044 } else {
045 exchange.setException(new RollbackExchangeException(exchange));
046 }
047 }
048
049 @Override
050 public String toString() {
051 if (message != null) {
052 return "Rollback[" + message + "]";
053 } else {
054 return "Rollback";
055 }
056 }
057
058 public String getTraceLabel() {
059 return "Rollback";
060 }
061 }