[CONF] Apache Camel > Infinispan
Bilgin Ibryam edited the page: Infinispan ... Code Block xml messageId In c For more information, see these resources... ... View Online · Like · View Changes Stop watching space · Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel > Infinispan
Bilgin Ibryam edited the page:
Infinispan
...
Code Block
java
from("direct:start")
.setHeader(InfinispanConstants.OPERATION, constant(InfinispanConstants.GET))
.setHeader(InfinispanConstants.KEY, constant("123"))
.to("infinispan://localhost?cacheContainer=#cacheContainer");
Using the Infinispan based idempotent repository
In this section we will use the Infinispan based idempotent repository.
First, we need to create a cacheManager and then configure our
org.apache.camel.component.infinispan.processor.idempotent.InfinispanIdempotentRepository:
Code Block
xml
[CONF] Apache Camel > Infinispan
Ugo Landini edited the page: Infinispan ... Maven users will need to add the following dependency to their pom.xml for this component: Code Block xml org.apache.camel camel-infinispan x.x.x URI format Code Block infinispan://hostName?[options] ... The producer allows sending messages to a local infinispan cache configured in the registry, or to a remote cahe cache using the HotRod protocol. The consumer allows listening for events from local infinispan cache accessible from the registry. ... Below is an example route that retrieves a value from the cahe cache for a specific key: Code Block
[CONF] Apache Camel > Infinispan
Infinispan
Page edited by Bilgin Ibryam
Changes (1)
...
{code}
infinispan://hostName?[options]
{code}
...
Full Content
Infinispan Component
Available as of Camel 2.13.0
This component allows you to interact with Infinispan distributed data grid / cache. Infinispan is an extremely scalable, highly available key/value data store and data grid platform written in Java.
Maven users will need to add the following dependency to their pom.xml for this component:
org.apache.camel
camel-infinispan
x.x.x
URI format
infinispan://hostName?[options]
URI Options
The producer allows sending messages to a local infinispan cache configured in the registry, or to a remote cahe using the HotRod protocol.
The consumer allows listening for events from local infinispan cache accessible from the registry.
Name
Default Value
Type
Context
Description
cacheContainer
null
CacheContainer
Shared
Reference to a org.infinispan.manager.CacheContainer in the Registry.
cacheName
null
String
Shared
The cache name to use. If not specified, default cache is used.
command
PUT
String
Producer
The operation to perform. Currently supports the following values: PUT, GET, REMOVE, CLEAR.
eventTypes
null
Set
Consumer
The event types to register. By default will listen for all event types. Possible values defined in org.infinispan.notifications.cachelistener.event.Event.Type
sync
true
Boolean
Consumer
By default the consumer will receive notifications synchronosly, by the same thread that process the cache operation.
Message Headers
Name
Default Value
Type
Context
Description
CamelInfinispanCacheName
null
String
Shared
The cache participating in the operation or event.
CamelInfinispanOperation
PUT
String
Producer
The operation to perform: CamelInfinispanOperationPut, CamelInfinispanOperationGet, CamelInfinispanOperationRemove, CamelInfinispanOperationClear.
CamelInfinispanKey
null
Object
Shared
The key to perform the operation to or the key generating the event.
CamelInfinispanValue
null
Object
Producer
The value to use for the operation.
CamelInfinispanOperationResult
null
Object
Producer
The result of the operation.
CamelInfinispanEventType
null
String
Consumer
The type of the received event. Possible values defined here org.infinispan.notifications.cachelistener.event.Event.Type
CamelInfinispanIsPre
null
Boolean
Consumer
Infinispan fires two events for each operation: one before and one after the operation.
Example
Below is an example route that retrieves a value from the cahe for a specific key:
from("direct:start")
.setHeader(InfinispanConstants.OPERATION, constant(InfinispanConstants.GET))
.setHeader(InfinispanConstants.KEY, constant("123"))
.to("infinispan://localhost?cacheContainer=#cacheContainer");
For more information, see these resources...
See Also
Configuring Camel
Component
Endpoint
Getting Started
Stop watching space
|
Change email notification preferences
View Online
|
View Changes
[CONF] Apache Camel > Infinispan
Infinispan
Page added by Bilgin Ibryam
Infinispan Component
Available as of Camel 2.13.0
This component allows you to interact with Infinispan distributed data grid / cache. Infinispan is an extremely scalable, highly available key/value data store and data grid platform written in Java.
Maven users will need to add the following dependency to their pom.xml for this component:
org.apache.camel
camel-infinispan
x.x.x
URI format
infinispan://host?[options]
URI Options
The producer allows sending messages to a local infinispan cache configured in the registry, or to a remote cahe using the HotRod protocol.
The consumer allows listening for events from local infinispan cache accessible from the registry.
Name
Default Value
Type
Context
Description
cacheContainer
null
CacheContainer
Shared
Reference to a org.infinispan.manager.CacheContainer in the Registry.
cacheName
null
String
Shared
The cache name to use. If not specified, default cache is used.
command
PUT
String
Producer
The operation to perform. Currently supports the following values: PUT, GET, REMOVE, CLEAR.
eventTypes
null
Set
Consumer
The event types to register. By default will listen for all event types. Possible values defined in org.infinispan.notifications.cachelistener.event.Event.Type
sync
true
Boolean
Consumer
By default the consumer will receive notifications synchronosly, by the same thread that process the cache operation.
Message Headers
Name
Default Value
Type
Context
Description
CamelInfinispanCacheName
null
String
Shared
The cache participating in the operation or event.
CamelInfinispanOperation
PUT
String
Producer
The operation to perform: CamelInfinispanOperationPut, CamelInfinispanOperationGet, CamelInfinispanOperationRemove, CamelInfinispanOperationClear.
CamelInfinispanKey
null
Object
Shared
The key to perform the operation to or the key generating the event.
CamelInfinispanValue
null
Object
Producer
The value to use for the operation.
CamelInfinispanOperationResult
null
Object
Producer
The result of the operation.
CamelInfinispanEventType
null
String
Consumer
The type of the received event. Possible values defined here org.infinispan.notifications.cachelistener.event.Event.Type
CamelInfinispanIsPre
null
Boolean
Consumer
Infinispan fires two events for each operation: one before and one after the operation.
Example
Below is an example route that retrieves a value from the cahe for a specific key:
from("direct:start")
.setHeader(InfinispanConstants.OPERATION, constant(InfinispanConstants.GET))
.setHeader(InfinispanConstants.KEY, constant("123"))
.to("infinispan://localhost?cacheContainer=#cacheContainer");
For more information, see these resources...
See Also
Configuring Camel
Component
Endpoint
Getting Started
Stop watching space
|
Change email notification preferences
View Online
