Open Red Hat CodeReady Studio.

当您首次启动 CodeReady Studio 时，它会在 JBoss 视角中打开：

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

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

在 Project Name 字段中，输入 ZooOrderApp。

保留选中 Use default workspace location 选项。

点 Next 打开 Select a Target Runtime 页面：

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

接受默认的 Apache Camel 版本。

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

点 Finish。

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

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

单击 Yes 。

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

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

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

打开 Editor 首选项页面：

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

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

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

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

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

点 Source 选项卡。

XML 文件在 Editor 视图中打开。

例如，message1.xml 文件的内容显示来自 Bronx Zoo for 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>

将文件组件 从面板的Components drawer 拖到 canvas，并将它放到 Route_route1 容器节点上。

File 组件会更改为 Route _route1 容器节点内的来自 _from 1 节点。

在 canvas 上，选择 From _from1 节点。

Properties 视图（位于 canvas 下）显示节点用于编辑的属性字段。

要指定消息文件的源目录，在 Properties 视图中点 Advanced 标签页：

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

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

在 Consumer 选项卡中，点 Noop 选项启用其复选框。

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

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

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

将自动生成的 Id 保留为。

从 面板的 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>

在 面板上，打开 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 字段中，type: /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 process。

将剩余的属性保留原样。

在 canvas 中，单击 Log_log2 节点。

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

注意

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

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

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

将剩余的属性保留原样。

在 canvas 中，点 SetHeader_setHeader2 节点。

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

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

保存 路由上下文文件。

已完成的基于内容的路由器应如下所示：

点底部的 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 node。

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

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

在 Properties 视图中：

保存文件。

Route_route2 美国分支应如下所示：

在 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 pattern ( )，然后点击 Log_ger 节点。

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

在 Properties 视图中：

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

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

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

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

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

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

对于每个四个变量：

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

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

右键单击 MessageBody 以打开其上下文菜单，然后选择 更改值 ：

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

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

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

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

点 进入下一步。

message3 现在遵循导致To_Fulfill 和 Route_route2 的分支，而不是跟随 To_Invalid 的分支。

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

点 进入下一个断点：

debugger 在禁用的断点上跳过，并跳转到 _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 选项卡的最右侧，并将它放到其中：

此安排提供了更多空间，以便诊断路由上下文的节点以图形方式显示路由上下文的节点，从而可以更轻松地查看消息遍历路由上下文的路径。

注意

为了便于访问路由上下文 .xml 文件，特别是当项目由多个上下文组成时，工具会在 Project Explorer 中的 Camel Contexts 文件夹下列出它们。

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

选择 Run As → Local Camel Context （不带测试）。

在 JMX Navigator 中，展开 本地进程。

扩展路由的元素：

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

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

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

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

Drag message1.xml 将其放到 _context1>Endpoints>file>src/data?noop=true 节点上：

当消息会遍历路由时，工具追踪并记录其传递。

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

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

在 Configure Columns 向导中，以这种方式选择并排序列：

这些列及其顺序将保留在 消息视图中， 直到您再次更改它们。

在 Messages View 中，点 （刷新按钮）使用 message2.xml 消息跟踪填充视图。

每次丢弃 JMX Navigator 中的消息时，您需要刷新 Messages View 以填充消息跟踪。

点击其中一个信息跟踪在 Properties 视图中查看它的更多详情：

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

您可以通过突出显示消息实例来逐步浏览消息实例，以查看特定消息如何遍历路由，以及路由中每个步骤是否按预期处理。

打开 Diagram View 以查看路由中的相关步骤已突出显示：

这些工具以 图表 视图中提取路由，标记路径退出处理步骤，包含时间和性能指标（以毫秒为单位）。图中仅显示 指标 Total Exchange。

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

另外，您可以随时将 ZooOrderApp/src/data/ 中的其余消息拖放到 _context1>Endpoints>file>src/data?noop=true 节点（只要仍然启用追踪）。

在每个后续丢弃中，请记住点 （刷新按钮）使用新消息跟踪填充 Messages View。

完成后：

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

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

图 9.1. 跟踪生成的消息

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

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

确保 ZooOrderApp/src 出现在 Enter 或选择 parent folder 字段中。

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

点 Finish。

在 Project Explorer 中，新的 src/test/java 文件夹会出现在 src/main/resources 文件夹下：

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

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

在 test 字段下的 Camel XML 文件中，点 打开配置为过滤 XML 文件的文件 explorer，然后选择 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;

使用这些 受保护的 String body#; 行替换这些行来保护的 Object[] expectedBodies={ …​…​ expectedBody2</something>"}; iwl-DESTINATION to these 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# = FileUtils.readFileToString (new File ("src/data/message#.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> 部分的末尾添加以下行：

<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 “跟踪生成的消息”）。

点 No servers are available.点击此链接来创建新 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 Server 的运行时定义，并打开 Fuse 服务器配置详情页面 ：

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

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

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

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

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

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

这是在 Red Hat Fuse 的 installDir/etc/users.properties 文件中或 karaf jaas 命令中设置的密码。

点 Finish。

运行时服务器 [stopped, Synchronized] 会出现在 Servers 视图中。

在 Servers 视图中，展开 Runtime Server：

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

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

确保启用了 资源更改时 Automatically publish publish 选项。

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

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

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

确保 选项 如果启动了 server，则将立即检查发布更改。

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

点 Finish。

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

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

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

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

注意

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

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

选择 Add and Remove:

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

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