/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You 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.apache.camel.model; import javax.xml.bind.annotation.XmlAccessType; import javax.xml.bind.annotation.XmlAccessorType; import javax.xml.bind.annotation.XmlAttribute; import javax.xml.bind.annotation.XmlRootElement; import org.apache.camel.Expression; import org.apache.camel.Processor; import org.apache.camel.model.language.ExpressionDefinition; import org.apache.camel.processor.LoopProcessor; import org.apache.camel.spi.RouteContext; /** * Represents an XML <loop/> element * * @version */ @XmlRootElement(name = "loop") @XmlAccessorType(XmlAccessType.FIELD) public class LoopDefinition extends ExpressionNode { @XmlAttribute private Boolean copy; public LoopDefinition() { } public LoopDefinition(Expression expression) { super(expression); } public LoopDefinition(ExpressionDefinition expression) { super(expression); } /** * Enables copy mode so a copy of the input Exchange is used for each iteration. * That means each iteration will start from a copy of the same message. *
* By default loop will loop the same exchange all over, so each iteration may * have different message content. * * @return the builder */ public LoopDefinition copy() { setCopy(true); return this; } public void setExpression(Expression expr) { setExpression(ExpressionNodeHelper.toExpressionDefinition(expr)); } public Boolean getCopy() { return copy; } public void setCopy(Boolean copy) { this.copy = copy; } public boolean isCopy() { // do not copy by default to be backwards compatible return copy != null ? copy : false; } @Override public String toString() { return "Loop[" + getExpression() + " -> " + getOutputs() + "]"; } @Override public String getLabel() { return "loop[" + getExpression() + "]"; } @Override public String getShortName() { return "loop"; } @Override public Processor createProcessor(RouteContext routeContext) throws Exception { Processor output = this.createChildProcessor(routeContext, true); return new LoopProcessor(output, getExpression().createExpression(routeContext), isCopy()); } }