工具 Tutorials

打开 Red Hat CodeReady Studio。

首次启动 CodeReady Studio 时，它会在 JBoss 透视图中打开：

否则，它会在之前 CodeReady Studio 会话中使用的视角中打开。

在菜单中，选择 File → New → Fuse Integration Project 以打开 New Fuse Integration Project 向导：

在 Project Name 字段中，输入 ZooOrderApp。

保留 Use default 工作区位置 选项被选择。

点 Next 以打开 Select a Target Runtime 页面：

选择 Karaf/Fuse on Karaf 并接受为运行时 选择的 None。

接受默认的 Apache Camel 版本。

点 Next 以打开 Advanced Project Setup 页面，然后选择 Empty - Blueprint DSL 模板：

点 Finish。

Fuse 工具开始从 Maven 存储库下载 - 所有需要构建项目的文件，然后将新项目添加到 Project Explorer 视图。

如果 CodeReady Studio 尚未显示 Fuse Integration 视角，它会询问您现在是否要切换到它：

单击 Yes 。

新的 ZooOrderApp 项目在 Fuse Integration 视角中打开：

ZooOrderApp 项目包含创建和运行路由所需的所有文件，包括：

要查看初始路由上下文，请在 Editor 视图中打开 blueprint.xml 文件，然后点 Source 选项卡。

打开 Editor 首选项页面：

检查 所有组件标签的 Use ID 值。

在 CodeReady Studio Project Explorer 视图中，创建一个文件夹来包含测试消息：

点击此处 打开 Web 浏览器，进入提供的工具工具 Tutorial 资源 Fuse-tooling-tutorials-jbds-10.3.zip 文件的位置。

将 Fuse-tooling-tutorials-jbds-10.3.zip 文件下载到 ZooOrderApp 项目工作区外部的便捷位置，然后将其解压缩。它包含两个文件夹，如 第 1 章 关于 Fuse 工具 Tutorials 所述。

从 messages 文件夹，将六个 XML 文件复制到 ZooOrderApp 项目的 src/data 文件夹。

点 Source 选项卡。

XML 文件在 Editor 视图中打开。

例如，message1.xml 文件的内容显示来自 Bronx Zoo 为 12 个 wombats 的顺序：

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

将文件组件组件 拖到 canvas 中，并将它放到 Route_route1 容器节点中。

File 组件会更改为 Route_route1 容器节点内的 From _from1 节点。

在 canvas 上，选择 From _from1 节点。

Properties 视图位于 canvas 下，显示节点的属性字段进行编辑。

要为消息文件指定源目录，在 Properties 视图中点 Advanced 选项卡：

在 Directory Name 字段中，输入 src/data ：

路径 src/data 相对于项目的目录。

在 Consumer 选项卡中，点 Noop 选项来启用 Noop 选项。

Noop 选项可防止 消息 Serial.xml 文件从 src/data 文件夹中删除，并启用 idempotency 来确保每个 message#.xml 文件只消耗一次。

选择 Details 选项卡，以打开文件节点的 Details 页面。

请注意，工具会自动使用您在 Advanced 选项卡上配置的 Directory Name 和 Noop 属性填充 Uri 字段。它还使用自动生成的 ID (_from1)填充 Id 字段：

将自动生成的 Id 保留为原样。

将 另一个文件 组件从 PrometheusRule 的Components drawer 拖放，并将它放到 Route_route1 容器节点上。

File 组件会更改为 Route_route1 容器节点内的 To_to1 节点。

在 canvas 上，选择 To_to1 节点。

Properties 视图位于 canvas 下，显示节点的属性字段进行编辑。

在 Details 标签页中：

在 Route_route1 容器中，选择 From _from1 节点，并将其连接器箭头( )拖到 To_Received 节点上，然后释放它：

点击 canvas 底部的 Source 选项卡来显示路由的 XML：

<?xml version="1.0" encoding="UTF-8"?>

<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

    <camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <to id="_Received" uri="file:target/messages/received"/>
        </route>
    </camelContext>
</blueprint>

下面是其中之一：

在 Project Explorer 中，选择 ZooOrderApp/Camel Contexts/blueprint.xml ：

右键单击 blueprint.xml，然后选择 Run As → Local Camel Context （无需测试）。

Console 面板将打开，以显示反映项目执行进度的日志消息。开始时，Maven 下载更新本地 Maven 存储库所需的资源。Maven 下载过程可能需要几分钟时间。

等待消息（与以下内容类似）在输出末尾出现：这些消息表示路由成功执行：

...
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Route: _route1 started and consuming from:Endpoint[file://src/data?noop=true]
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Total 1 routes, of which 1 are started.
[Blueprint Event Dispatcher: 1]BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.163 seconds
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.918 seconds

在 Project Explorer 中，找到 target/messages/ 文件夹并展开，以验证 target/messages/received 文件夹是否包含六个消息文件 message1.xml 到 message6.xml ：

双击 message1.xml 在路由编辑器的 Design 选项卡中打开它，然后选择 Source 选项卡来查看 XML 代码：

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

在 Prod 中，打开 Routing drawer，单击 Choice ( )模式，然后（在 Design canvas 中），单击 From_from1 节点。

Route_route1 容器扩展以容纳 Choice_choice1 节点。错误图标表示 Choice_choice1 节点需要您接下来添加的子节点。

在 Routing drawer 中，点 When ( )模式，然后在 canvas 中点 Choice_choice1 节点。

Choice_choice1 容器扩展以适应 When_when1 节点：

拒绝 When_when1 节点表示必须设置一个或多个所需的属性值。

在 canvas 上，选择 When_when1 节点，在 Properties 视图中打开其属性：

选择 xpath （用于 XML 查询语言），因为测试消息使用 XML 编写。

在缩进 Expression 字段中，键入： /order/orderline/quantity/text （）> 10

此表达式指定，只有 quantity 字段的值大于路由中的 10 个传输此路径（到 invalidOrders 文件夹）的消息。

保留每个剩余的属性。

点 Source 选项卡查看路由的 XML：

在 canvas 中，点 When_when1 节点。

When_when1 容器扩展以容纳 Log_log1 节点：

在 Message 字段中，键入： 请求的数量超过允许的最大 - 联系客户。

在 canvas 中，单击 Log_log1 节点。

When_when1 容器扩展以容纳 SetHeader_setHeader1 节点：

在 canvas 上，选择 SetHeader_setHeader1 节点在 Properties 视图中打开其属性：

其余的属性保留原样。

在 canvas 中，点 SetHeader_setHeader1 节点。

When_when1 容器扩展以容纳 To_to1 节点。

在 canvas 上，选择 To_to1 节点在 Properties 视图中打开其属性：

在 Details 标签页中，将 directoryName 替换为 Uri 字段中的 target/messages/invalidOrders，并在 Id 字段中键入 _Invalid ：

点 Source 选项卡查看路由的 XML：

在 canvas 中，点 Choice_choice1 容器：

Choice_choice1 容器展开，以适应 Otherwise_otherwise1 节点。

在 Id 字段中，将 _otherwise1 改为 _elseValid ：

在 canvas 中，点 Otherwise_elseValid 节点：

Otherwise-elseValid 容器展开，以容纳 Log_log2 节点。

在 Message 字段中，键入 This is a valid order - OK to process.

其余的属性保留原样。

在 canvas 中，单击 Log_log2 节点。

Otherwise_elseValid 容器展开，以适应 SetHeader_setHeader2 节点。

注意

当图表被拥塞时，您可以折叠容器来释放空间。要做到这一点，选择要折叠的容器，然后点击其 按钮：

要重新打开容器，请选择它，然后点击其 按钮：

在 Design 选项卡中，联合和扩展容器不会影响路由上下文文件。它保持不变。

其余的属性保留原样。

在 canvas 中，点 SetHeader_setHeader2 节点。

Otherwise_elseValid 容器展开，以适应 To_to1 节点。

在 URI 字段中，将 directoryName 替换为 target/messages/validOrders，然后在 Id 字段中键入 _Valid。

保存 路由上下文文件。

已完成的基于内容的路由器应类似如下：

单击 canvas 左下方的 Source 选项卡，以显示路由的 XML。

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

<camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <choice id="_choice1">
                <when id="_when1">
                    <xpath>/order/orderline/quantity/text() &gt; 10</xpath>
                    <log id="_log1" message="The quantity requested exceeds the maximum allowed - contact customer."/>
                    <setHeader headerName="Destination" id="_setHeader1">
                        <constant>Invalid</constant>
                    </setHeader>
                    <to id="_Invalid" uri="file:target/messages/invalidOrders"/>
                </when>
                <otherwise id="_elseValid">
                    <log id="_log2" message="This is a valid order - OK to process."/>
                    <setHeader headerName="Destination" id="_setHeader2">
                        <constant>ReadyForDispatcher</constant>
                    </setHeader>
                    <to id="_Valid" uri="file:target/messages/validOrders"/>
                </otherwise>
            </choice>
        </route>
    </camelContext>
</blueprint>

在项目根节点(ZooOrderApp)下，找到 target/messages/ 文件夹并将其展开。

检查 target/messages/invalidOrders 文件夹是否包含 message1.xml 和 message3.xml。

在这些消息中，quantity 元素的值会超过 10。

检查 target/messages/validOrders 文件夹是否包含包含有效顺序的四个消息文件：

在 canvas 中，点 Route_route1 容器右侧的：

Route 模式成为 canvas 上的 Route_route2 容器节点。

在 canvas 中，点 Route_route2 容器：

Route_route2 容器扩展以容纳 Direct 组件( From_from2 节点)：

在 Uri 字段中，将 name (following direct:)替换为 OrderFulfillment，然后在 Id 字段中输入 _direct:OrderFulfillment。

在 canvas 中，点 From _direct:OrderFulfillment 节点。

Route_route2 容器扩展以适应 Choice_choice2 节点：

在 Properties 视图中，保留 Choice_choice2 节点的属性。

在 canvas 中，单击 Choice_choice2 节点。

Choice_choice2 容器扩展了，以适应 When_when2 节点。

设置 When_when2 节点的属性，如下所示：

在 canvas 中，点 When_when/usa 容器。

When_when/usa 容器扩展以容纳 To_to1 节点。

在 Properties 视图中：

在 canvas 中，点 When_when/usa 节点。

When_when/usa 容器扩展以容纳 SetHeader_setHeader3 节点：

设置节点的属性，如下所示：

在 canvas 中，点 SetHeader 节点之上。

When_when/usa 容器扩展以容纳 Log_log3 节点。

在 canvas 上，选择 Log_log3 节点以在 Properties 视图中打开其属性：

在 Properties 视图中：

保存该文件。

Route_route2 的 USA 分支应类似如下：

在 canvas 中，单击 Choice_choice2 容器。

Choice_choice2 容器展开，以适应 Otherwise_otherwise1 节点。

在 canvas 中，单击 Otherwise_else/ger 节点。

Otherwise_else/ger 容器展开，以适应 SetHeader_setHeader3 节点。

在 Properties 视图中：

在 canvas 中，点 SetHeader_setHead_ger 节点下。

Otherwise_else/ger 容器扩展，以适应 Log_log3 节点。如果需要，将连接器错误从 Log_log3 节点拖到 SetHeader_setHead_ger 节点：

在 Properties 视图中：

在 Components drawer 中，选择一个 File 模式( )，然后点击 Log_ger 节点下的文件模式。

Otherwise_else/ger 容器扩展，以适应 To_to1 节点。如果需要，将连接器错误从 SetHeader_setHead_ger 节点拖到 To_to1 节点：

在 Properties 视图中：

检查控制台输出的末尾。您应该看到以下行：

检查目标目标文件夹以验证路由是否已正确执行：

在 canvas 上，选择 Choice_choice1 节点，然后点击其 图标设置无条件断点：

在以下 Route_Route1 节点上设置无条件断点：

在以下 Route_Route2 节点上设置无条件断点：

在第一个断点上停止了 message1，在 _route1 [blueprint.xml] 中 停止 _choice1，将变量 NodeId 和 RouteId （在 Exchange category 中）和 MessageBody 和 CamelFileName （在 Message 类别中）添加到监视列表中。

对于每个变量：

将变量 Destination 添加到 watch 列表中。

Expressions 视图现在应包含这些变量：

右键点击 MessageBody 以打开其上下文菜单，然后选择 Change Value ：

将 数量 的值从 15 改为 10 （将其从无效顺序更改为有效顺序）：

这只更改内存值（它不会编辑 message3.xml 文件）。

切换到 Expressions 视图，然后选择 MessageBody 变量。

变量列表下的窗格显示 message3 的整个正文，从而可以轻松地检查订购项目的当前值：

点 进入下一个断点。

message3 现在遵循 To_Fulfill 和 Route_ route2 的分支，而不是遵循发送到To_Fulfill 和 Route_route2 的分支。

切换到 Breakpoints 视图，然后清除 _choice1 下列出的断点旁边的每个复选框。清除断点的复选框会临时禁用它。

点 进入下一个断点：

调试器跳过禁用的断点并跳转到 _route1 [blueprint.xml] 中的 _FulFill。

再次点 来进入下一个断点：

debugger 在 _route2 [blueprint.xml] 中跳转到 _GER。

在工具栏中，点 终止 Camel 调试器：

扩展 ZooOrderApp/target/messages/ 目录，以检查消息是否按预期发送：

您应该会看到只有 message1 发送到 invalidOrders，并且 message3.xml 会出现在 validOrders/Germany 文件夹中。

点工具栏右侧的 按钮，然后从列表中选择 Fuse Integration ：

Fuse Integration 视角在默认布局中打开：

将 JMX Navigator 选项卡拖到 Terminal 选项卡的最右侧，并将其保存在：

此安排为 Diagram View 提供了更多空间，以便以图形方式显示路由上下文的节点，这样您可以更轻松地跟踪消息在遍历路由上下文中的路径。

注意

为了轻松访问路由上下文 .xml 文件，特别是项目包含多个上下文时，工具会在 Project Explorer 的 Camel Contexts 文件夹下列出它们。

此外，路由上下文中的所有路由都直接显示为图标，在其上下文文件条目下直接显示。要在 canvas 上的路由上下文中显示单个路由，请在 Project Explorer 中双击其图标。要显示路由上下文中的所有路由，请双击上下文文件条目。

选择 Run As → Local Camel Context （没有测试）。

在 JMX 导航器 中，展开 Local process。

扩展路由的元素：

右键点击 Routes 节点，然后选择 Start Tracing ：

该工具在 图表 View 中显示路由上下文的图形表示：

要查看所有消息流路径，您可能需要通过拖动节点以在 Diagram View 选项卡中重新安排节点。您可能还需要调整 Red Hat CodeReady Studio 中其他视图和标签页的大小，以允许 Diagram View 选项卡扩展。

在 Project Explorer 中，展开 ZooOrderApp/src/data，以便您可以访问消息文件(message1.xml 到 message6.xml)：

Drag message1.xml 并将它放到 JMX Navigator 中的 _context1>Endpoints>file>src/data?noop=true 节点上：

当消息遍历路由时，工具会跟踪并记录每个步骤的 passage。

点面板菜单栏中的 图标，然后选择 Configure Columns 以打开 Configure Columns 向导：

您可以选择或取消选择 Messages View，从 Messages View 中包含或排除项目。您可以重新安排在 Messages View 中显示的列顺序，通过突出显示各个项目、选定项目并在列表中移动它们。

在 Configure Columns 向导中，选择并按顺序排序列：

这些列及其顺序将在 Messages View 中保留，直到您再次更改它们。

在 Messages View 中，点 (Refresh 按钮)使用 message2.xml 消息跟踪填充视图。

每次在 JMX Navigator 中丢弃消息时，您需要刷新 Messages View，以使用消息 trace 填充它。

点消息 trace 之一在 Properties 视图中查看它的详情：

工具在 Properties 视图的前半部分显示消息追踪（包括消息标头）的详细信息，以及 Properties 视图底部的消息实例的内容。因此，如果应用程序在路由中的任何步骤中设置标头，您可以检查 Message Details 以查看它们是否按预期设置。

您可以通过突出显示每个消息实例来逐步浏览消息实例，以了解特定消息如何遍历路由，并在路由中的每个步骤中按预期处理。

打开 图表 View，查看 路由中的关联步骤是否已突出显示：

工具在 Diagram View 中提取路由，标记路径退出具有计时和性能指标（以毫秒为单位）的处理步骤。图中仅显示指标 总交换。

将鼠标指针悬停在显示的指标上，以显示有关消息流的额外指标：

另外，您还可以将 ZooOrderApp/src/data/ 中剩余的信息拖放到 _context1>Endpoints>file>src/data?noop=true 节点（只要启用了追踪）。

在每个随后的 drop 中，点 (Refresh 按钮)为 Messages View 填充新消息 trace。

完成后：

要启动本教程，您需要从以下之一生成的 ZooOrderApp 项目：

从 Project Explorer 中的 ZooOrderApp 项目的 /src/data/ 目录和 /target/messages/ 子目录中删除任何 trace 生成的消息。trace 生成的消息以 ID- 前缀开头。例如： 图 9.1 “trace 生成的消息” 显示八个追踪生成的信息：

图 9.1. trace 生成的消息

选择批处理中的所有 trace-generated 消息，右键单击并选择 Delete。

在 New Folder 对话框中，在项目树窗格中展开 ZooOrderApp 节点，再选择 src 文件夹。

确保 ZooOrderApp/src 出现在 Enter 或选择父文件夹 字段中。

在 Folder name 中，输入 /test/java ：

点 Finish。

在 Project Explorer 中，新的 src/test/java 文件夹显示在 src/main/resources 文件夹下：

验证新的 /src/test/java 文件夹是否包含在构建路径中。

右键，然后选择 New → Camel Test Case。

在 test 字段中的 Camel XML 文件中，点 打开配置为过滤 XML 文件的文件管理器，然后选择 ZooOrderApp 项目的 blueprint.xml 文件：

点击 确定。Name 字段默认为 BlueprintXmlTest。

点 Next 以打开 Test Endpoints 页面。

默认情况下，会选择所有端点，并将包含在测试案例中。

点 Finish。

在 Project Explorer 中，展开 ZooOrderApp 项目，以公开 BlueprintXmlTest.java 文件：

添加以粗体文本显示的两行。根据下一部分的指示，添加第一行会导致当您更新 pom.xml 文件时解析的错误。

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.File;

将这些行替换有 保护的 Object[] expectedBodies={ …​…​ expectedBody2</something>"}; to these protected-busybox with those protected String body"; 行：

protected String body1; protected String body2; protected String body3; protected String body4; protected String body5; protected String body6;

向下滚动到行 public void testCamelRoute （）会抛出 Exception {，并在它后面直接插入行 body Serial = FileUtils.readFileToString (new File ("src/data/message failing.xml"), "UTF-8"); 如下所示。这些行将指示错误，直到您按照下一节中的指示更新 pom.xml 文件。

// Valid orders body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8"); body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8"); body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8"); body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8"); // Invalid orders body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8"); body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

将以 outputEndpoint.expectedBodiesReceivedInAnyOrder (expectedBodies) 开头的代码块替换为 …​inputEndpoint.sendBody (expectedBody); } 替换为此处显示的行：

// Invalid orders outputEndpoint.expectedBodiesReceived(body1, body3); // Valid orders for USA output3Endpoint.expectedBodiesReceived(body2, body5, body6); // Valid order for Germany output4Endpoint.expectedBodiesReceived(body4);

将剩余的代码保留原样。

检查您更新的 BlueprintXmlTest.java 文件是否具有所需的修改。它应该类似如下：

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.file;

public class BlueprintXmlTest extends CamelBlueprintTestSupport {

	// TODO Create test message bodies that work for the route(s) being tested
	// Expected message bodies
	protected String body1;
	protected String body2;
	protected String body3;
	protected String body4;
	protected String body5;
	protected String body6;
	// Templates to send to input endpoints
	@Produce(uri = "file:src/data?noop=true")
	protected ProducerTemplate inputEndpoint;
	@Produce(uri = "direct:OrderFulfillment")
	protected ProducerTemplate input2Endpoint;
	// Mock endpoints used to consume messages from the output endpoints and then perform assertions
	@EndpointInject(uri = "mock:output")
	protected MockEndpoint outputEndpoint;
	@EndpointInject(uri = "mock:output2")
	protected MockEndpoint output2Endpoint;
	@EndpointInject(uri = "mock:output3")
	protected MockEndpoint output3Endpoint;
	@EndpointInject(uri = "mock:output4")
	protected MockEndpoint output4Endpoint;

	@Test
	public void testCamelRoute() throws Exception {
		// Create routes from the output endpoints to our mock endpoints so we can assert expectations
		context.addRoutes(new RouteBuilder() {
			@Override
			public void configure() throws Exception {
				// Valid orders
				body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8");
				body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8");
				body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8");
				body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8");

				// Invalid orders
				body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8");
				body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

				from("file:target/messages/invalidOrders").to(outputEndpoint);
				from("file:target/messages/validOrders/USA").to(output3Endpoint);
				from("file:target/messages/validOrders/Germany").to(output4Endpoint);
				from("direct:OrderFulfillment").to(output2Endpoint);
			}
		});

		// Define some expectations

		// TODO Ensure expectations make sense for the route(s) we're testing
		// Invalid orders
		outputEndpoint.expectedBodiesReceived(body1, body3);

		// Valid orders for USA
		output3Endpoint.expectedBodiesReceived(body2, body5, body6);

		// Valid order for Germany
		output4Endpoint.expectedBodiesReceived(body4);

		// Validate our expectations
		assertMockEndpointsSatisfied();
	}

	@Override
	protected String getBlueprintDescriptor() {
		return "OSGI-INF/blueprint/blueprint.xml";
	}

}

将这些行添加到 < dependencies&gt; 部分的末尾：

<dependency>
       <groupId>commons-io</groupId>
       <artifactId>commons-io</artifactId>
       <version>2.5</version>
       <scope>test</scope>
</dependency>

选择 Run As → JUnit Test。

默认情况下，JUnit 视图在侧边栏中打开。（为了提供更好的视图，将其拖到底部，右面板显示 控制台、服务器以及 属性 选项卡。）

如果测试成功运行，您会看到类似如下的内容：

图 9.2. 成功 JUnit 运行

当测试失败时，您会看到类似如下的内容：

图 9.3. JUnit 运行失败

检查输出并采取措施来解决任何测试失败。

要查看 JUnit 面板中显示的更多错误，请单击面板菜单栏中的 以最大化视图。

在再次运行 JUnit 测试案例前，从 Project Explorer 中的 ZooOrderApp 项目的 /src/data 文件夹中删除所有 JUnit 生成的测试消息（请参阅 图 9.1 “trace 生成的消息”）。

点 No servers 可用。点击此链接来创建新 server…​ 链接，以打开 Define a New Server 页面。

扩展 Red Hat JBoss Middleware 节点以公开可用的服务器选项：

接受 服务器主机名(localhost)和 服务器名称 (Fuse n.n Runtime Server)的默认值，然后单击 Next 以打开 Runtime 页面：

从 Execution Environment 旁边的下拉菜单中选择运行时 JRE。

选择 JavaSE-1.8 （推荐）。如有必要，单击 Environments 按钮，将其从列表中选中。

点 Next 以保存 Fuse 服务器的运行时定义，并打开 Fuse 服务器配置详情页面 ：

接受 SSH 端口 的默认端口(8101)。

运行时使用 SSH 端口来连接服务器的 Karaf shell。如果此默认不正确，您可以通过在 Red Hat Fuse installDir/etc/org.apache.karaf.shell.cfg 文件中查找正确的端口号。

在 用户名 中，输入用于登录服务器的名称。

这是存储在 Red Hat Fuse installDir'/etc/users.properties' 文件中的用户名。

如果没有设置，您可以使用格式 user=password,role （如 joe=secret,Administrator）添加到该文件中，也可以使用 karaf jaas 命令集设置：

在 Password 中，键入 用户名 所需的密码以登录到服务器。

这是在红帽 Fuse 的 installDir/etc/users.properties 文件中或 karaf jaas 命令中设定的密码。

点 Finish。

Runtime Server [stopped, Synchronized] 会出现在 Servers 视图中。

在 Servers 视图中，展开 Runtime Server：

JMX[Disconnected] 在 Runtime Server [stopped, Synchronized] 条目下显示为节点。

在服务器的 Overview 页面中，展开 Publishing 部分以公开选项。

确保启用 资源更改时，自动发布 选项。

（可选）更改 发布间隔 值，以便在进行更改时加快或延迟发布项目。

等待几秒钟，使服务器启动。当它这样做时：

在 Servers 视图中，右键单击 n.n Runtime Server [Started]，然后选择 Add and Remove 以打开 Add 和 Remove 页面：

确保 如果服务器启动，则立即检查发布更改。

选择 ZooOrderApp 并点 Add 将其分配给 Fuse 服务器：

点 Finish。

Servers 视图应该显示以下内容：

在 JMX Navigator 中，展开 Camel 文件夹以公开 ZooOrderApp 的元素。

点 Bundles 节点，使用运行时服务器上安装的捆绑包列表填充 Properties 视图：

在 Search 字段中，键入 ZooOrderApp。显示对应的捆绑包：

注意

或者，您可以在 Terminal 视图中发出 osgi:list 命令，以查看在服务器运行时上安装的生成的捆绑包列表。该工具对 OSGi 捆绑包使用不同的命名方案，由 osgi:list 命令显示。在这种情况下，命令会返回 Camel Blueprint Quickstart，它出现在安装捆绑包列表的末尾。

在项目的 pom.xml 文件的 < build > 部分中，您可以找到捆绑包的符号链接名称及其捆绑包名称(OSGi)在 maven-bundle-plugin 条目中列出的：

选择 "添加和删除" ：

在 Servers 视图中，右键单击 JMX[Connected]，然后单击 Refresh。

JMX[Connected] 下的 Camel 树会消失。