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 */ 017package org.apache.camel.processor; 018 019import org.apache.camel.AsyncCallback; 020import org.apache.camel.AsyncProcessor; 021import org.apache.camel.Exchange; 022import org.apache.camel.Expression; 023import org.apache.camel.Traceable; 024import org.apache.camel.spi.IdAware; 025import org.apache.camel.support.ServiceSupport; 026import org.apache.camel.util.AsyncProcessorHelper; 027import org.apache.camel.util.ObjectHelper; 028 029/** 030 * A processor which sets the property on the exchange with an {@link org.apache.camel.Expression} 031 */ 032public class SetPropertyProcessor extends ServiceSupport implements AsyncProcessor, Traceable, IdAware { 033 private String id; 034 private final Expression propertyName; 035 private final Expression expression; 036 037 public SetPropertyProcessor(Expression propertyName, Expression expression) { 038 this.propertyName = propertyName; 039 this.expression = expression; 040 ObjectHelper.notNull(propertyName, "propertyName"); 041 ObjectHelper.notNull(expression, "expression"); 042 } 043 044 public void process(Exchange exchange) throws Exception { 045 AsyncProcessorHelper.process(this, exchange); 046 } 047 048 @Override 049 public boolean process(Exchange exchange, AsyncCallback callback) { 050 try { 051 Object newProperty = expression.evaluate(exchange, Object.class); 052 053 if (exchange.getException() != null) { 054 // the expression threw an exception so we should break-out 055 callback.done(true); 056 return true; 057 } 058 059 String key = propertyName.evaluate(exchange, String.class); 060 exchange.setProperty(key, newProperty); 061 } catch (Throwable e) { 062 exchange.setException(e); 063 } 064 065 callback.done(true); 066 return true; 067 } 068 069 @Override 070 public String toString() { 071 return "SetProperty(" + propertyName + ", " + expression + ")"; 072 } 073 074 public String getTraceLabel() { 075 return "setProperty[" + propertyName + ", " + expression + "]"; 076 } 077 078 public String getId() { 079 return id; 080 } 081 082 public void setId(String id) { 083 this.id = id; 084 } 085 086 public String getPropertyName() { 087 return propertyName.toString(); 088 } 089 090 public Expression getExpression() { 091 return expression; 092 } 093 094 @Override 095 protected void doStart() throws Exception { 096 // noop 097 } 098 099 @Override 100 protected void doStop() throws Exception { 101 // noop 102 } 103}