3.4. 在集成中发布 AMQ 消息

流程

1. 在 Add to Integration 页面上，单击您要添加连接的加号。如果 Fuse Online 正在提示您选择完成连接，请跳过这一步。
2. 点流中您要的 Red Hat AMQ 连接。

3. 在 Choose an action 页面中，选择以下操作之一：

   • 发布消息以将 消息 发布到您指定的队列或主题。配置此操作：

     1. 在 Destination name 字段中，输入要发送消息的队列或主题的名称。
     2. 对于 Destination 类型，接受 队列 或选择 主题。
     3. 选择 Persistent 以保证消息发送，即使连接失败也是如此。

   • 使用消息 将消息发送到您指定的和接收响应的 JMS 目的地来请求响应。配置此操作：

     1. 在 Destination name 字段中，输入要发送消息的队列或主题的名称。
     2. 对于 Destination 类型，接受 队列 或选择 主题。

     3. 在 Message selector 字段中，如果只想接收满足特定条件的响应，请输入过滤器表达式。

        消息选择器是包含表达式的字符串。表达式的语法基于 SQL92 条件表达式语法的子集。以下示例中的消息选择器选择具有 NewsType 属性的任何消息，其值设为 Sports 或 Opinion ：

        NewsType = ’Sports’ OR NewsType = ’Opinion’

        消息消费者仅接收那些标头和属性与消息选择器表达式匹配的消息。消息选择器无法根据消息正文的内容选择消息。

     4. 在 Named reply to 字段中，输入队列或主题的名称。目标将其响应发送到此队列或主题。
     5. 选择 Persistent 以保证消息发送，即使连接失败也是如此。
     6. 在 Response time out 字段中，指定此连接在抛出运行时异常前等待响应消息的毫秒数。默认值为 5000 毫秒(5 秒)。
4. 单击 Next 以指定操作的输入类型，然后单击操作的输出类型。

5. 在 Select Type 字段中，如果不需要知道数据类型，则接受 类型规格， 然后点 Next。您不需要遵循这些指令的其余部分。

   但是，建议使用结构化的数据类型。例如，如果要在数据映射器步骤中映射连接输入/输出，您必须指定数据类型。数据映射器无法显示非结构化数据的字段。

   要指定数据类型，点 Select Type 字段，并选择以下之一作为 schema 类型：

   • JSON 模式是 描述 JSON 数据结构的文档。文档的介质类型是 application/schema+json。
   • JSON 实例 是包含 JSON 数据的文档。文档的介质类型是 application/json。
   • XML 模式 是一个描述 XML 数据结构的文档。文档的文件扩展为 .xsd。
   • XML 实例 是包含 XML 数据的文档。文档的文件扩展为 .xml。
6. 在 Definition 输入框中，粘贴符合您选择的 schema 类型的定义。例如，如果您选择 JSON 模式，您将粘贴 JSON 模式文件的内容，该文件的介质类型为 application/schema+json。

7. 在 Data Type Name 字段中输入您为数据类型选择的名称。例如，如果您要为供应商指定 JSON 模式，您可以指定 Vendor 作为数据类型名称。

   在创建或编辑使用指定此类型的连接时，您将看到此数据类型名称。Fuse Online 在集成视觉化和数据映射程序中显示类型名称。

8. 在 Data Type Description 字段中，提供可帮助您区分此类型的信息。当您将鼠标悬停在处理此类型的步骤上时，此描述会出现在数据映射程序中。
9. 点击 Next。