Apache Camel：来自Exchange标头到另一个路线的数据

Question

我不得不询问骆驼路线的行为，这是愚蠢（但易于理解）的逻辑描述。 在主题中 - 我需要将信息从一条路线的交换标头推送到另一条路线。 都是关于CMDB系统和监控工具zabbix的。 好吧，首先我有一个可以在 CMDB 中切换 CI 状态的路由：

<route>
    <description> route catching CI ID in jms queue, check it on exist and switch CI state to incident
    </description>
    <from uri="jms:switchCIStateQueue"/>
    <filter>
        <simple>${body} regex '[\d]+'</simple>
        <to uri="bean:otrsCIApi?method=getCIBodyByID(${body})"/>
        <filter>
            <simple>${body} regex '\{.+?\}'</simple>
            <marshal>
                <json library="Jackson"/>
            </marshal>
            <unmarshal>
                <json library="Jackson" unmarshalTypeName="ts.team.otrs.ci.OtrsCI"/>
            </unmarshal>
            <to uri="bean:otrsCIApi?method=switchOTRSCIState(${body})"/>
        </filter>
    </filter>
</route>

它运行良好，但我必须从另一条路线使用此操作，该路线有许多检查、过滤器和选择。 我的问题是我没有 CI ID 作为主体（但将其保留在标题中）在主要逻辑路线的深度。

<route>
    <description>Route catch triggerid 
     and creates a ticket in OTRS, link it to host
    </description>
    <from uri="direct:zab_trig_2_otrs_tick"/>
    <to uri="bean:zabbixApi?method=getTriggerByID(body)"/>
    <filter>
        <simple>${body} regex '\{.+?\}'</simple>
            <marshal>
                <json library="Jackson"/>
            </marshal> 
            <unmarshal>
                 <json library="Jackson" unmarshalTypeName="ts.team.zabbix.trigger.SingleTrigger"/>
            </unmarshal>
            <setHeader headerName="ZabbixTrigger" id="_setZabbixTrigger">
                <simple>${body}</simple>
            </setHeader>
            <!-- search CI in OTRS -->
            <to uri="bean:otrsCIApi?method=searchCI(${body.getHosts().get(0).getName()})"/>
            <!-- Array of CI ID like [] or ["1"] -->
            <split streaming="true">
                <simple>${body}</simple>
                <!-- place it in header-->
                <setHeader headerName="HostID">
                    <simple>${body}</simple>
                </setHeader>
                <to uri="bean:otrsLinkApi?method=ListLinkedTicketsTitleFiltered(${body},${header.ZabbixTrigger.getDescription()})"/>
                <!-- return JSONArray  with State=open otrs Tickets ID -->
                <choice>
                    <when id="ticketslist_empty">
                        <simple>${body} == ''</simple>
                        <!-- Create ticket, connect it to host in OTRS -->
                        <to uri="bean:otrsTicketApi?method=createNewTicket(${header.ZabbixTrigger.getDescription()},${header.ZabbixTrigger.getPriority()})"/>
                        <!-- return body body with ticket id, create link with  ${header.HostID} -->
                        <to uri="bean:otrsLinkApi?method=LinkAdd(${header.HostID},${body})"/>
                        <!-- Here i need to switch CI state if incident priority is higher than 3(Normal)-->
                        <when>
                            <simple>${header.ZabbixTrigger.getPriority()} > 3</simple>
                            <!-- here i need to send  ${header.HostID} to previous described route (jms:switchCIStateQueue)-->
                        </when>
                    </when>
                </choice>
            </split>
    </filter>
</route>

所以，这条路线有一段：

                    <when>
                        <simple>${header.ZabbixTrigger.getPriority()} > 3</simple>
                        <!-- here i need to send  ${header.HostID} to previous described route (jms:switchCIStateQueue)-->
                    </when>

我需要将一些信息从我的标头发送到 jms:switchCIStateQueue （或直接路由，无论到哪里）。 我希望，我对问题的描述非常完整和简单。

Answer 1

好的。 你问了两个问题：

1. 我需要将 CIID 推送到第一个描述的路由中

您必须将 jms 消息推送到 jms:switchCIStateQueue 所以，在你的源路线（第二个“大”）它应该是这样的：

<to uri="jms:switchCIStateQueue"/>

Exchange 标头中的任何内容都将在 JMS 消息标头中。 Exchange 消息体将是 JMS 消息体。 如果您将按原样在源路由中执行此操作，则将有 JMS 标头 HostID 并且您的第一个获取该 JMS 消息的路由可以作为 ${header.HostID} 访问它

然后取决于您的 otrsCIApi.getCIBodyByID 期望什么以及您的呼叫可能是什么样子

一个。 <to uri="bean:otrsCIApi?method=getCIBodyByID(${header.HostID})"/>

b.但是，如果“getCIBodyByID”的预期参数具有与 CIID 更多的结构/格式，则必须在将其发送到队列（在“大”路由中）或从队列中获取消息后正确构建它。

1. 如何将 ${header.HostID} 放入正文中

这又取决于预期的 JMS 消息body 的结构/格式是什么

一个。只需将 HostID 标头值原样放在正文中：

<when>
     <simple>${header.ZabbixTrigger.getPriority()} > 3</simple>
       <!-- here i set  ${header.HostID} into body -->
       <body>
         <simple>${header.HostID}</simple>
       </body>
        <!-- here i can set  ${header.HostID} into another header if i'd like to  -->
        <setHeader headerName="CIID">
                        <simple>${header.HostID}</simple>
        </setHeader>
        <!-- finally I send message to queue -->
        <to uri="jms:switchCIStateQueue"/> 
</when>

b.不仅仅是 CIID 值 - 根据需要构建它（代替 <body> 元素，可能会有处理器或其他 bean 方法调用来执行此操作。

我是否正确理解了您的问题，是您正在寻找的问题吗？