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

subscribeMapEventstrueSet if consumer should subscribe to Map events
filteredMapEventsnull

The list of Map event type to filer, valid values are:

  • INSERT
  • UPDATE
  • REMOVE
subscribeTopologicalEventsfalseSet if consumer should subscribe to TopologicalEvents
subscribeTopicEventsfalseSet if consumer should subscribe to TopicEvents
actionnull

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
persistenttrueEnable/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

ChronicleEngineTopologicalEventFullNamejava.lang.StringThe full name of the TopologicalEvent
ChronicleEngineTopologicalEventAddedjava.lang.String 
ChronicleEngineMapEventTypeChronicleEngineMapEventTypeThe map event type
ChronicleEngineResultjava..lang.ObjectThe result of an operation
ChronicleEngineQueueIndexlongThe index of the event being published
ChronicleEngineKeyjava.lang.StringThe key
ChronicleEngineDefaultValuejava..lang.ObjectThe default value for operations that support default value
ChronicleEngineOldValuejava..lang.ObjectThe old value associated to a key
ChronicleEngineActionjava.lang.String The action to perform

 

 

 

  • No labels