Chronicle Engine Component
Available as of Camel 2.18
The chronicle component let you leverage the power of OpenHFT's Chronicle-Engine in Apache Camel.
Maven users will need to add the following dependency to their pom.xml
for this component:
<dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-chronicle</artifactId> <version>x.x.x</version> <!-- use the same version as your Camel core version --> </dependency>
URI format
chronicle-engine://addresses/path[?options]
You can append query options to the URI in the following format, ?option=value&option=#beanRef&...
Options
Name | Default Value | Description |
---|---|---|
wireType | BINARY | The Wire type to use, default is binary wire |
subscribeMapEvents | true | Set if consumer should subscribe to Map events |
filteredMapEvents | null | The list of Map event type to filer, valid values are:
|
subscribeTopologicalEvents | false | Set if consumer should subscribe to TopologicalEvents |
subscribeTopicEvents | false | Set if consumer should subscribe to TopicEvents |
action | null | The default action to perform, valid values are:
|
persistent | true | Enable/disable data persistence |
Header variables
Name | Type | Description |
---|---|---|
ChronicleEngineAssetName | java.lang.String | The asset name |
ChronicleEnginePath | java.lang.String | The data path |
ChronicleEngineTopic | java.lang.Object | A topic |
ChronicleEngineTopologicalEventName | java.lang.String | The name of the TopologicalEvent |
ChronicleEngineTopologicalEventFullName | java.lang.String | The full name of the TopologicalEvent |
ChronicleEngineTopologicalEventAdded | java.lang.String | |
ChronicleEngineMapEventType | ChronicleEngineMapEventType | The map event type |
ChronicleEngineResult | java..lang.Object | The result of an operation |
ChronicleEngineQueueIndex | long | The index of the event being published |
ChronicleEngineKey | java.lang.String | The key |
ChronicleEngineDefaultValue | java..lang.Object | The default value for operations that support default value |
ChronicleEngineOldValue | java..lang.Object | The old value associated to a key |
ChronicleEngineAction | java.lang.String | The action to perform |