如何正确配置这个骆驼路由XML？

Question

widget_id | widget_name | widget_value
(INT)       (VARCHAR 50)  (INT)

null

我希望每隔5分钟轮询这个toprocess队列（使用Camel-Quartz)，并将这些consumes消息主体中找到的字符串(fizz、buzz等）合并到JDBCselect语句中，该语句查找widget_name与字符串（例如fizz或buzz）匹配的任何小部件。

然后，我要获取从JDBC调用中检索的每个widget记录，并将其放在ready队列中。最后，burninatorbean应该使用ready并将每个WidgetPOJO传递给其burninator#burninate(Widget)方法。

所以总结一下：

1. 外部进程在toprocess队列
上放置字符串，如“fizz”
2. 骆驼-石英作业每5分钟触发一次，并“fizz”（和任何其他）排队
3. camel-jdbcselect*FROM widgets WHERE widget_name='fizz'-->我怀疑我需要XPath
4. 假设查询返回25小部件记录
5. 所有25个都被序列化（binary/json/xml？）并放置在就绪队列
上
6. 一个接一个地burninator#burninate(Widget)出列ready，并与下一个出列的Widget
一起执行

以下是我目前所掌握的，但我知道这是错误的：

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
    <package>com.myapp.bus</package>
    <template id="camelTemplate"/>
    <route>
        <from uri="quartz://toProcessPollerJob?cron=*+5+*+*+*+?"/>
        <to uri="activemq:toProcess"/>
        <setBody>
            <constant>
                SELECT
                    *
                FROM
                    widgets
                WHERE
                    widget_name = ??? (e.g., fizz, buzz)
            </constant>
        </setBody>
        <marshall>
            <serialization/>
        </marshall>
        <to uri="activemq:ready"/>
        <unmarshall>
            <serialization/>
        </unmarshall>
        <to uri="bean:burninator?method=burninate"/>
    </route>
</camelContext>

有没有骆驼巫师可以在这里给我指明正确的方向（除了参考《骆驼在行动中》中我应该读的那一章；-））。具体地说，我遇到了麻烦：

null




Answer 1

你需要使用一些其他的语言而不是常量，因为它只是一个常量。例如，simple、groovy，甚至像velocity这样的模板语言，在这些语言中创建要使用的SQL。

尝试…

<simple>
            SELECT
                *
            FROM
                widgets
            WHERE
                widget_name = '${body}'
</simple>

在http://camel.apache.org/languages可以看到支持的语言吗