第 161 章 Ignite Queues 组件

作为 Camel 2.17 版提供

Ignite Queue 端点是一个 camel-ignite 端点,可让您与 Ignite Queue 数据结构 交互。

此端点仅支持制作者。

161.1. 选项

Ignite Queues 组件支持 4 个选项,它们如下所列。

名称描述默认类型

ignite (producer)

设置 Ignite 实例。

 

Ignite

configurationResource (producer)

设置从中加载配置的资源。它可以是: URI、String (URI)或 InputStream。

 

对象

igniteConfiguration (producer)

允许用户设置程序化 IgniteConfiguration。

 

IgniteConfiguration

resolveProperty Placeholders (advanced)

启动时,组件是否应自行解析属性占位符。只有 String 类型的属性才能使用属性占位符。

true

布尔值

Ignite Queues 端点使用 URI 语法进行配置:

ignite-queue:name

使用以下路径和查询参数:

161.1.1. 路径名(1 参数):

名称描述默认类型

name

所需的 队列名称。

 

字符串

161.1.2. 查询参数(7 参数):

名称描述默认类型

capacity (producer)

队列容量。默认:非绑定。

 

int

configuration (producer)

集合配置。默认:空配置。您还可以使用 configuration.xyz=123 选项方便地设置内部属性。

 

CollectionConfiguration

operation (producer)

在 Ignite Queue 上调用的操作。被 IN 消息中的 IgniteConstants.IGNITE_QUEUE_OPERATION 标头取代。可能的值有: CONTAINS, ADD, SIZE, REMOVE, ITERATOR, CLEAR, RETAIN_ALL, ARRAY, DRAIN, ELEMENT, PEEK, OFFER, POLL, TAKE, PUT.

 

IgniteQueueOperation

propagateIncomingBodyIfNo ReturnValue (producer)

如果底层 Ignite 操作的返回类型为 void,则设置是否传播传入的正文。

true

布尔值

timeoutMillis (producer)

队列超时(毫秒)。默认:无超时。

 

Long

treatCollectionsAsCache Objects (producer)

设置是否将集合视为缓存对象,还是作为项目集合来插入/更新/计算等。

false

布尔值

同步 (高级)

设置同步处理是否应当严格使用,还是允许 Camel 使用异步处理(如果受支持)。

false

布尔值