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>
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: - PUBLISH
- PUBLISH_AND_INDEX
- PUT
- GET_AND_PUT
- PUT_ALL
- PUT_IF_ABSENT
- GET
- GET_AND_REMOVE
- REMOVE
- IS_EMPTY
- SIZE
|
| persistent | true | Enable/disable data persistence |
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 |
