第 154 章 Ignite Cache 组件

cacheName

所需的 缓存名称。

字符串

propagateIncomingBodyIfNo ReturnValue (common)

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

true

布尔值

treatCollectionsAsCache Objects (common)

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

false

布尔值

autoUnsubscribe (consumer)

是否在持续查询消费者中启用自动取消订阅。

true

布尔值

bridgeErrorHandler (consumer)

允许将消费者桥接到 Camel 路由 Error Handler，这意味着使用者试图获取传入消息或类似信息时出现任何异常，现在将作为一个消息进行处理，并由路由 Error Handler 处理。默认情况下，使用者将使用 org.apache.camel.spi.Exception 处理程序处理异常，该处理程序将记录在 WARN 或 ERROR 级别，并忽略。

false

布尔值

fireExistingQueryResults (consumer)

是否处理与查询匹配的现有结果。用于初始化持续查询使用者。

false

布尔值

oneExchangePerUpdate (consumer)

是否要在单独交换中打包每个更新，即使在一个批内收到多个更新。仅限持续查询使用者使用。

true

布尔值

pageSize (consumer)

页面大小。仅限持续查询使用者使用。

1

int

query (consumer)

要执行的查询，仅需要它的操作，以及持续查询消费者的操作。

Object>>

remoteFilter (consumer)

远程过滤器，仅由 Continuous Query Consumer 使用。

Object>

timeInterval (consumer)

持续查询使用者的时间间隔。

0

long

exceptionHandler (consumer)

要让使用者使用自定义 ExceptionHandler。请注意，如果启用了选项 bridgeErrorHandler，则不使用这个选项。默认情况下，消费者处理异常，这将在 WARN 或 ERROR 级别记录，并忽略。

ExceptionHandler

exchangePattern (consumer)

在使用者创建交换时设置交换模式。

ExchangePattern

cachePeekMode (producer)

CachePeekMode，只适用于需要它的操作（链接 IgniteCacheOperationSIZE）。

ALL

CachePeekMode

failIfInexistentCache (producer)

如果缓存不存在，是否会导致初始化失败。

false

布尔值

operation (producer)

要调用的缓存操作。可能的值有：GET、PUT、REMOVE、SIZE、REBALANCE、QUERY、CLEAR.

IgniteCacheOperation

同步 （高级）

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

false

布尔值

CamelIgniteCacheKey

IgniteConstants.IGNITE_CACHE_KEY

字符串

消息正文中条目值的 cache 键。

CamelIgniteCacheQuery

IgniteConstants.IGNITE_CACHE_QUERY

查询

调用 QUERY 操作时要运行的查询（生成器）。

CamelIgniteCacheOperation

IgniteConstants.IGNITE_CACHE_OPERATION

IgniteCacheOperation enum

允许您将缓存操作动态更改为执行（生成程序）。

CamelIgniteCachePeekMode

IgniteConstants.IGNITE_CACHE_PEEK_MODE

CachePeekMode enum

允许您在运行 SIZE 操作时动态更改 cache peek 模式。

CamelIgniteCacheEventType

IgniteConstants.IGNITE_CACHE_EVENT_TYPE

int (EventType constants)

当使用持续查询消费者时，此标头会传输接收的事件类型。

CamelIgniteCacheName

IgniteConstants.IGNITE_CACHE_NAME

字符串

此标头传输接收持续查询事件（消费者）的缓存名称。它不允许您动态更改执行制作者操作的缓存。将 EIP 用于该 （如接收者列表、动态路由器）。

CamelIgniteCacheOldValue

IgniteConstants.IGNITE_CACHE_OLD_VALUE

对象

当传递传入缓存事件(consumer)时，此标头会传输旧的缓存值。