Apache Camel 在交换标头中设置路由异常

Question

我正在使用 Camel sql 组件，并希望在事务失败时使用 onConsumeFailed 更新具有异常堆栈跟踪的记录。

表结构： 如果不存在，则创建表 库存（ itemnbr 整数 非空默认值 nextval（'inventory_itemnbr_seq'：：regclass）， 位置整数， 位置类型字符变化 （2） ， 颜色字符变化 （5） ， 品牌字符变化 （5）， soh 双精度， camel_is_read整数默认值 0， 异常字符变化 （500） ， 约束inventory_pkey主键 （itemnbr） ）

在我的骆驼路线中，我使用了onConsumerFailed选项，如下所示

sql://<select statement>?dataSource=#dataSource&onConsumeFailed=update inventory set camel_is_read = 0, exception=:#exception where itemNbr= :#itemNbr

我已经在路由上创建了 onException，如下所示，并将标头属性“异常”的根本原因设置为 .

     onException(Exception.class).process(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
            Throwable ex = exchange.getProperty(Exchange.EXCEPTION_CAUGHT,
                    Throwable.class);
                    exchange.getIn().setHeader("exception", ex.getCause());
        }
    });

当事务发生异常时，更新行时会抛出以下错误

org.apache.camel.RuntimeExchangeException:Cannot find key [exception] in message body or headers to use when setting named parameter in query

我们如何在路由执行期间从路由访问标头属性？

Answer 1

您可以使用简单的表达式语言来获得异常

异常=：#$｛异常｝

https://camel.apache.org/components/next/languages/simple-language.html