第 137 章 Hazelcast Ringbuffer 组件

作为 Camel 版本 2.16 可用

Avalaible from Camel 2.16

Hazelcast ringbuffer 组件是 Camel Hazelcast 组件之一，它可让您访问 Hazelcast ringbuffer。Ringbuffer 是一个分布式数据结构，其数据存储在类环形结构中。您可以将其视为具有特定容量的循环数组。

137.1. 选项
复制链接

Hazelcast Ringbuffer 组件支持以下列出的 3 个选项。

Expand

名称	描述	默认	类型
hazelcastInstance (advanced)	hazelcast 实例参考，可用于 hazelcast 端点。如果没有指定实例引用，则 camel 使用 camel-hazelcast 实例中的默认 hazelcast 实例。		HazelcastInstance
hazelcastMode (advanced)	应使用哪种实例的 hazelcast 模式。如果没有指定模式，则节点模式将是默认设置。	node	字符串
resolveProperty Placeholders (advanced)	启动时，组件是否应自行解析属性占位符。只有 String 类型的属性才能使用属性占位符。	true	布尔值

Hazelcast Ringbuffer 端点使用 URI 语法进行配置：

hazelcast-ringbuffer:cacheName

hazelcast-ringbuffer:cacheName

Copy to Clipboard

Toggle word wrap

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

Expand

名称	描述	默认	类型
cacheName	所需的缓存名称		字符串

Expand

名称	描述	默认	类型
reliable (common)	定义端点是否使用可靠的主题结构。	false	布尔值
defaultOperation (producer)	要指定要使用的默认操作，如果没有提供操作标头。		HazelcastOperation
hazelcastInstance (producer)	hazelcast 实例参考，可用于 hazelcast 端点。		HazelcastInstance
hazelcastInstanceName (producer)	hazelcast 实例参考名称，可用于 hazelcast 端点。如果没有指定实例引用，则 camel 使用 camel-hazelcast 实例中的默认 hazelcast 实例。		字符串
同步（高级）	设置同步处理是否应当严格使用，还是允许 Camel 使用异步处理（如果受支持）。	false	布尔值
concurrentConsumers (seda)	使用并发消费者从 SEDA 队列进行轮询。	1	int
onErrorDelay (seda)	发生错误后使用者继续轮询前的毫秒。	1000	int
pollTimeout (seda)	从 SEDA 队列消耗的超时。发生超时时，消费者可以检查是否允许继续运行。设置较低值可让使用者在关闭时更快地响应。	1000	int
已翻译 (seda)	如果设置为 true，则消费者以事务模式运行，只有在事务提交完成时，seda 队列中的消息才会被删除。	false	布尔值
transferExchange (seda)	如果设置为 true，则将传输整个交换。如果标头或正文不包含序列化对象，则会跳过它们。	false	布尔值

返回顶部