홈
제품
Red Hat build of Apache Camel
4.0
Red Hat build of Apache Camel for Spring Boot Reference
Chapter 42. Infinispan Embedded

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 42. Infinispan Embedded

Since Camel 2.13

Both producer and consumer are supported

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.

The camel-infinispan-embedded component includes the following features.

Local Camel Consumer - Receives cache change notifications and sends them to be processed. This can be done synchronously or asynchronously, and is also supported with a replicated or distributed cache.
Local Camel Producer - A producer creates and sends messages to an endpoint. The camel-infinispan producer uses GET, PUT, REMOVE, and CLEAR operations. The local producer is also supported with a replicated or distributed cache.

The events are processed asynchronously.

42.1. Dependencies
링크 복사

When using infinispan-embedded with Red Hat build of Camel Spring Boot make sure to use the following Maven dependency to have support for auto configuration:

<dependency>
  <groupId>org.apache.camel.springboot</groupId>
  <artifactId>camel-infinispan-embedded-starter</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel core version -->
</dependency>

<dependency>
  <groupId>org.apache.camel.springboot</groupId>
  <artifactId>camel-infinispan-embedded-starter</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel core version -->
</dependency>

Copy to Clipboard

Toggle word wrap

42.2. URI format
링크 복사

infinispan-embedded://cacheName?[options]

infinispan-embedded://cacheName?[options]

Copy to Clipboard

Toggle word wrap

The producer allows sending messages to a local infinispan cache. The consumer allows listening for events from local infinispan cache.

If no cache configuration is provided, embedded cacheContainer is created directly in the component.

42.3. Configuring Options
링크 복사

Camel components are configured on two separate levels.

component level
endpoint level

42.3.1. Configuring Component Options
링크 복사

The component level is the highest level which holds general and common configurations that are inherited by the endpoints. For example a component may have security settings, credentials for authentication, urls for network connection and more.

Because components typically have pre configured defaults that are commonly used, then you may often only need to configure a few options on a component; or none at all.

Configuring components can be done with the Component DSL, in a configuration file (application.properties|yaml), or directly with Java code.

42.3.2. Configuring Endpoint Options
링크 복사

Endpoints have many options, which allows you to configure what you need the endpoint to do. The options are also categorized into whether the endpoint is used as consumer (from) or as a producer (to), or used for both.

Configuring endpoints is done directly in the endpoint URI as path and query parameters. You can also use the Endpoint DSL and DataFormat DSL as a type safe way of configuring endpoints and data formats in Java.

Use Property Placeholders to configure options that allows to not hardcode urls, port numbers, sensitive information, and other settings. In other words placeholders allows to externalize the configuration from your code, and gives more flexibility and reuse.

The following two sections lists all the options, firstly for the component followed by the endpoint.

42.4. Component Options
링크 복사

The Infinispan Embedded component supports 20 options that are listed below.

Expand

Name	Description	Default	Type
configuration (common)	Component configuration.		InfinispanEmbeddedConfiguration
queryBuilder (common)	Specifies the query builder.		InfinispanQueryBuilder
bridgeErrorHandler (consumer)	Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.	false	boolean
clusteredListener (consumer)	If true, the listener will be installed for the entire cluster.	false	boolean
customListener (consumer)	Returns the custom listener in use, if provided.		InfinispanEmbeddedCustomListener
eventTypes (consumer)	Specifies the set of event types to register by the consumer.Multiple event can be separated by comma. The possible event types are: CACHE_ENTRY_ACTIVATED, CACHE_ENTRY_PASSIVATED, CACHE_ENTRY_VISITED, CACHE_ENTRY_LOADED, CACHE_ENTRY_EVICTED, CACHE_ENTRY_CREATED, CACHE_ENTRY_REMOVED, CACHE_ENTRY_MODIFIED, TRANSACTION_COMPLETED, TRANSACTION_REGISTERED, CACHE_ENTRY_INVALIDATED, CACHE_ENTRY_EXPIRED, DATA_REHASHED, TOPOLOGY_CHANGED, PARTITION_STATUS_CHANGED, PERSISTENCE_AVAILABILITY_CHANGED.		String
sync (consumer)	If true, the consumer will receive notifications synchronously.	true	boolean
defaultValue (producer)	Set a specific default value for some producer operations.		Object
key (producer)	Set a specific key for producer operations.		Object
lazyStartProducer (producer)	Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.	false	boolean
oldValue (producer)	Set a specific old value for some producer operations.		Object
operation (producer)	The operation to perform. Enum values: * PUT * PUTASYNC * PUTALL * PUTALLASYNC * PUTIFABSENT * PUTIFABSENTASYNC * GET * GETORDEFAULT * CONTAINSKEY * CONTAINSVALUE * REMOVE * REMOVEASYNC * REPLACE * REPLACEASYNC * SIZE * CLEAR * CLEARASYNC * QUERY * STATS * COMPUTE * COMPUTEASYNC	PUT	InfinispanOperation
value* (producer)	Set a specific value for producer operations.		Object
autowiredEnabled (advanced)	Whether auto-wiring is enabled. This is used for automatic auto-wiring options (the option must be marked as auto-wired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.	true	boolean
cacheContainer (advanced)	Autowired Specifies the cache Container to connect.		EmbeddedCacheManager
cacheContainerConfiguration (advanced)	Autowired The CacheContainer configuration. Used if the cacheContainer is not defined.		Configuration
configurationUri (advanced)	An implementation specific URI for the CacheManager.		String
flags (advanced)	A comma separated list of org.infinispan.context.Flag to be applied by default on each cache invocation.		String
remappingFunction (advanced)	Set a specific remappingFunction to use in a compute operation.		BiFunction
resultHeader (advanced)	Store the operation result in a header instead of the message body. By default, resultHeader == null and the query result is stored in the message body, any existing content in the message body is discarded. If resultHeader is set, the value is used as the name of the header to store the query result and the original message body is preserved. This value can be overridden by an in message header named: CamelInfinispanOperationResultHeader.		String

42.5. Endpoint Options
링크 복사

The Infinispan Embedded endpoint is configured using URI syntax.

infinispan-embedded:cacheName

infinispan-embedded:cacheName

Copy to Clipboard

Toggle word wrap

Following are the path and query parameters.

42.5.1. Path Parameters (1 parameters)
링크 복사

Expand

Name	Description	Default	Type
cacheName (common)	Required The name of the cache to use. Use current to use the existing cache name from the currently configured cached manager. Or use default for the default cache manager name.		String

42.5.2. Query Parameters (20 parameters)
링크 복사

Expand

Name	Description	Default	Type
queryBuilder (common)	Specifies the query builder.		InfinispanQueryBuilder
clusteredListener (consumer)	If true, the listener will be installed for the entire cluster.	false	boolean
customListener (consumer)	Returns the custom listener in use, if provided.		InfinispanEmbeddedCustomListener
eventTypes (consumer)	Specifies the set of event types to register by the consumer.Multiple event can be separated by comma. The possible event types are: CACHE_ENTRY_ACTIVATED, CACHE_ENTRY_PASSIVATED, CACHE_ENTRY_VISITED, CACHE_ENTRY_LOADED, CACHE_ENTRY_EVICTED, CACHE_ENTRY_CREATED, CACHE_ENTRY_REMOVED, CACHE_ENTRY_MODIFIED, TRANSACTION_COMPLETED, TRANSACTION_REGISTERED, CACHE_ENTRY_INVALIDATED, CACHE_ENTRY_EXPIRED, DATA_REHASHED, TOPOLOGY_CHANGED, PARTITION_STATUS_CHANGED, PERSISTENCE_AVAILABILITY_CHANGED.		String
sync (consumer)	If true, the consumer will receive notifications synchronously.	true	boolean
bridgeErrorHandler (consumer (advanced))	Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.	false	boolean
exceptionHandler (consumer (advanced))	To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.		ExceptionHandler
exchangePattern (consumer (advanced))	Sets the exchange pattern when the consumer creates an exchange. Enum values: * InOnly * InOut * InOptionalOut		ExchangePattern
defaultValue (producer)	Set a specific default value for some producer operations.		Object
key (producer)	Set a specific key for producer operations.		Object
oldValue (producer)	Set a specific old value for some producer operations.		Object
operation (producer)	The operation to perform. Enum values: * PUT * PUTASYNC * PUTALL * PUTALLASYNC * PUTIFABSENT * PUTIFABSENTASYNC * GET * GETORDEFAULT * CONTAINSKEY * CONTAINSVALUE * REMOVE * REMOVEASYNC * REPLACE * REPLACEASYNC * SIZE * CLEAR * CLEARASYNC * QUERY * STATS * COMPUTE * COMPUTEASYNC	PUT	InfinispanOperation
value (producer)	Set a specific value for producer operations.		Object
lazyStartProducer (producer (advanced))	Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.	false	boolean
cacheContainer (advanced)	Autowired Specifies the cache Container to connect.		EmbeddedCacheManager
cacheContainerConfiguration (advanced)	Autowired The CacheContainer configuration. Used if the cacheContainer is not defined.		Configuration
configurationUri (advanced)	An implementation specific URI for the CacheManager.		String
flags (advanced)	A comma separated list of org.infinispan.context.Flag to be applied by default on each cache invocation.		String
remappingFunction (advanced)	Set a specific remappingFunction to use in a compute operation.		BiFunction
resultHeader (advanced)	Store the operation result in a header instead of the message body. By default, resultHeader == null and the query result is stored in the message body, any existing content in the message body is discarded. If resultHeader is set, the value is used as the name of the header to store the query result and the original message body is preserved. This value can be overridden by an in message header named: CamelInfinispanOperationResultHeader.		String

42.6. Message Headers
링크 복사

The Infinispan Embedded component supports 22 message headers that are listed below.

Expand

Name	Description	Default	Type
CamelInfinispanEventType (consumer) Constant: `EVENT_TYPE`	The type of the received event.		String
CamelInfinispanIsPre (consumer) Constant: `IS_PRE`	true if the notification is before the event has occurred, false if after the event has occurred.		boolean
CamelInfinispanCacheName (common) Constant: `CACHE_NAME`	The cache participating in the operation or event.		String
CamelInfinispanKey (common) Constant: `KEY`	The key to perform the operation to or the key generating the event.		Object
CamelInfinispanValue (producer) Constant: `VALUE`	The value to use for the operation.		Object
CamelInfinispanDefaultValue (producer) Constant: `DEFAULT_VALUE`	The default value to use for a getOrDefault.		Object
CamelInfinispanOldValue (producer) Constant: `OLD_VALUE`	The old value to use for a replace.		Object
CamelInfinispanMap (producer) Constant: `MAP`	A Map to use in case of CamelInfinispanOperationPutAll operation.		Map
CamelInfinispanOperation (producer) Constant: `OPERATION`	The operation to perform. Enum values: * PUT * PUTASYNC * PUTALL * PUTALLASYNC * PUTIFABSENT * PUTIFABSENTASYNC * GET * GETORDEFAULT * CONTAINSKEY * CONTAINSVALUE * REMOVE * REMOVEASYNC * REPLACE * REPLACEASYNC * SIZE * CLEAR * CLEARASYNC * QUERY * STATS * COMPUTE * COMPUTEASYNC		InfinispanOperation
CamelInfinispanOperationResult (producer) Constant: `RESULT`	The name of the header whose value is the result.		String
CamelInfinispanOperationResultHeader (producer) Constant: `RESULT_HEADER`	Store the operation result in a header instead of the message body.		String
CamelInfinispanLifespanTime (producer) Constant: `LIFESPAN_TIME`	The Lifespan time of a value inside the cache. Negative values are interpreted as infinity.		long
CamelInfinispanTimeUnit (producer) Constant: `LIFESPAN_TIME_UNIT`	The Time Unit of an entry Lifespan Time. Enum values: * NANOSECONDS * MICROSECONDS * MILLISECONDS * SECONDS * MINUTES * HOURS * DAYS		TimeUnit
CamelInfinispanMaxIdleTime (producer) Constant: `MAX_IDLE_TIME`	The maximum amount of time an entry is allowed to be idle for before it is considered as expired.		long
CamelInfinispanMaxIdleTimeUnit (producer) Constant: `MAX_IDLE_TIME_UNIT`	The Time Unit of an entry Max Idle Time. Enum values: * NANOSECONDS * MICROSECONDS * MILLISECONDS * SECONDS * MINUTES * HOURS * DAYS		TimeUnit
CamelInfinispanIgnoreReturnValues (consumer) Constant: `IGNORE_RETURN_VALUES`	Signals that write operation’s return value are ignored, so reading the existing value from a store or from a remote node is not necessary.	false	boolean
CamelInfinispanEventData (consumer) Constant: `EVENT_DATA`	The event data.		Object
CamelInfinispanQueryBuilder (producer) Constant: `QUERY_BUILDER`	The QueryBuilder to use for QUERY command, if not present the command defaults to InifinispanConfiguration’s one.		InfinispanQueryBuilder
CamelInfinispanCommandRetried (consumer) Constant: `COMMAND_RETRIED`	This will be true if the write command that caused this had to be retried again due to a topology change.		boolean
CamelInfinispanEntryCreated (consumer) Constant: `ENTRY_CREATED`	Indicates whether the cache entry modification event is the result of the cache entry being created.		boolean
CamelInfinispanOriginLocal (consumer) Constant: `ORIGIN_LOCAL`	true if the call originated on the local cache instance; false if originated from a remote one.		boolean
CamelInfinispanCurrentState (consumer) Constant: `CURRENT_STATE`	True if this event is generated from an existing entry as the listener has Listener.		boolean

42.7. Camel Operations
링크 복사

This section lists all available operations along with their header information.

Expand

Table 42.1. Table 1. Put Operations
Operation Name	Description
InfinispanOperation.PUT	Puts a key/value pair in the cache, optionally with expiration
InfinispanOperation.PUTASYNC	Asynchronously puts a key/value pair in the cache, optionally with expiration
InfinispanOperation.PUTIFABSENT	Puts a key/value pair in the cache if it did not exist, optionally with expiration
InfinispanOperation.PUTIFABSENTASYNC	Asynchronously puts a key/value pair in the cache if it did not exist, optionally with expiration

Required Headers:
- CamelInfinispanKey
- CamelInfinispanValue
Optional Headers:
- CamelInfinispanLifespanTime
- CamelInfinispanLifespanTimeUnit
- CamelInfinispanMaxIdleTime
- CamelInfinispanMaxIdleTimeUnit
Result Header:
- CamelInfinispanOperationResult

Expand

Table 42.2. Table 2. Put All Operations
Operation Name	Description
InfinispanOperation.PUTALL	Adds multiple entries to a cache, optionally with expiration
CamelInfinispanOperation.PUTALLASYNC	Asynchronously adds multiple entries to a cache, optionally with expiration

Required Headers:
- CamelInfinispanMap
Optional Headers:
- CamelInfinispanLifespanTime
- CamelInfinispanLifespanTimeUnit
- CamelInfinispanMaxIdleTime
- CamelInfinispanMaxIdleTimeUnit

Expand

Table 42.3. Table 3. Get Operations
Operation Name	Description
InfinispanOperation.GET	Retrieves the value associated with a specific key from the cache
InfinispanOperation.GETORDEFAULT	Retrieves the value, or default value, associated with a specific key from the cache

Required Headers:
- CamelInfinispanKey

Expand

Table 42.4. Table 4. Contains Key Operation
Operation Name	Description
InfinispanOperation.CONTAINSKEY	Determines whether a cache contains a specific key

Required Headers
- CamelInfinispanKey
Result Header
- CamelInfinispanOperationResult

Expand

Table 42.5. Table 5. Contains Value Operation
Operation Name	Description
InfinispanOperation.CONTAINSVALUE	Determines whether a cache contains a specific value

Required Headers:
- CamelInfinispanKey

Expand

Table 42.6. Table 6. Remove Operations
Operation Name	Description
InfinispanOperation.REMOVE	Removes an entry from a cache, optionally only if the value matches a given one
InfinispanOperation.REMOVEASYNC	Asynchronously removes an entry from a cache, optionally only if the value matches a given one

Required Headers:
- CamelInfinispanKey
Optional Headers:
- CamelInfinispanValue
Result Header:
- CamelInfinispanOperationResult

Expand

Table 42.7. Table 7. Replace Operations
Operation Name	Description
InfinispanOperation.REPLACE	Conditionally replaces an entry in the cache, optionally with expiration
InfinispanOperation.REPLACEASYNC	Asynchronously conditionally replaces an entry in the cache, optionally with expiration

Required Headers:
- CamelInfinispanKey
- CamelInfinispanValue
- CamelInfinispanOldValue
Optional Headers:
- CamelInfinispanLifespanTime
- CamelInfinispanLifespanTimeUnit
- CamelInfinispanMaxIdleTime
- CamelInfinispanMaxIdleTimeUnit
Result Header:
- CamelInfinispanOperationResult

Expand

Table 42.8. Table 8. Clear Operations
Operation Name	Description
InfinispanOperation.CLEAR	Clears the cache
InfinispanOperation.CLEARASYNC	Asynchronously clears the cache

Expand

Table 42.9. Table 9. Size Operation
Operation Name	Description
InfinispanOperation.SIZE	Returns the number of entries in the cache

Result Header
- CamelInfinispanOperationResult

Expand

Table 42.10. Table 10. Stats Operation
Operation Name	Description
InfinispanOperation.STATS	Returns statistics about the cache

Result Header:
- CamelInfinispanOperationResult

Expand

Table 42.11. Table 11. Query Operation
Operation Name	Description
InfinispanOperation.QUERY	Executes a query on the cache

Required Headers:
- CamelInfinispanQueryBuilder
Result Header:
- CamelInfinispanOperationResult

Note

Write methods like put(key, value) and remove(key) do not return the previous value by default.

42.8. Examples
링크 복사

Put a key/value into a named cache:

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.PUT) (1)
    .setHeader(InfinispanConstants.KEY).constant("123") (2)
    .to("infinispan:myCacheName&cacheContainer=#cacheContainer"); (3)

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.PUT) (1)
    .setHeader(InfinispanConstants.KEY).constant("123") (2)
    .to("infinispan:myCacheName&cacheContainer=#cacheContainer"); (3)

Copy to Clipboard

Toggle word wrap

Set the operation to perform
Set the key used to identify the element in the cache
Use the configured cache manager cacheContainer from the registry to put an element to the cache named myCacheName
It is possible to configure the lifetime and/or the idle time before the entry expires and gets evicted from the cache, as example.

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.GET)
    .setHeader(InfinispanConstants.KEY).constant("123")
    .setHeader(InfinispanConstants.LIFESPAN_TIME).constant(100L) (1)
    .setHeader(InfinispanConstants.LIFESPAN_TIME_UNIT.constant(TimeUnit.MILLISECONDS.toString()) (2)
    .to("infinispan:myCacheName");

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.GET)
    .setHeader(InfinispanConstants.KEY).constant("123")
    .setHeader(InfinispanConstants.LIFESPAN_TIME).constant(100L) (1)
    .setHeader(InfinispanConstants.LIFESPAN_TIME_UNIT.constant(TimeUnit.MILLISECONDS.toString()) (2)
    .to("infinispan:myCacheName");

Copy to Clipboard

Toggle word wrap

Set the lifespan of the entry
Set the time unit for the lifespan

Queries

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION, InfinispanConstants.QUERY)
    .setHeader(InfinispanConstants.QUERY_BUILDER, new InfinispanQueryBuilder() {
        @Override
        public Query build(QueryFactory<Query> qf) {
            return qf.from(User.class).having("name").like("%abc%").build();
        }
    })
    .to("infinispan:myCacheName?cacheContainer=#cacheManager") ;

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION, InfinispanConstants.QUERY)
    .setHeader(InfinispanConstants.QUERY_BUILDER, new InfinispanQueryBuilder() {
        @Override
        public Query build(QueryFactory<Query> qf) {
            return qf.from(User.class).having("name").like("%abc%").build();
        }
    })
    .to("infinispan:myCacheName?cacheContainer=#cacheManager") ;

Copy to Clipboard

Toggle word wrap

Custom Listeners
```
from("infinispan://?cacheContainer=#cacheManager&customListener=#myCustomListener")
  .to("mock:result");
```
```
from("infinispan://?cacheContainer=#cacheManager&customListener=#myCustomListener")
  .to("mock:result");
```
Copy to Clipboard Toggle word wrap
- The instance of myCustomListener must exist and Camel should be able to look it up from the Registry. Users are encouraged to extend the org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedCustomListener class and annotate the resulting class with @Listener which can be found in package org.infinispan.notifications.

42.9. Using the Infinispan based idempotent repository
링크 복사

Java Example

InfinispanEmbeddedConfiguration conf = new InfinispanEmbeddedConfiguration(); (1)
conf.setConfigurationUri("classpath:infinispan.xml")

InfinispanEmbeddedIdempotentRepository repo = new InfinispanEmbeddedIdempotentRepository("idempotent");  (2)
repo.setConfiguration(conf);

context.addRoutes(new RouteBuilder() {
    @Override
    public void configure() {
        from("direct:start")
            .idempotentConsumer(header("MessageID"), repo) (3)
            .to("mock:result");
    }
});

InfinispanEmbeddedConfiguration conf = new InfinispanEmbeddedConfiguration(); (1)
conf.setConfigurationUri("classpath:infinispan.xml")

InfinispanEmbeddedIdempotentRepository repo = new InfinispanEmbeddedIdempotentRepository("idempotent");  (2)
repo.setConfiguration(conf);

context.addRoutes(new RouteBuilder() {
    @Override
    public void configure() {
        from("direct:start")
            .idempotentConsumer(header("MessageID"), repo) (3)
            .to("mock:result");
    }
});

Copy to Clipboard

Toggle word wrap

Configure the cache
Configure the repository bean
Set the repository to the route

XML Example

<bean id="infinispanRepo" class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedIdempotentRepository" destroy-method="stop">
  <constructor-arg value="idempotent"/> (1)
  <property name="configuration"> (2)
    <bean class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedConfiguration">
      <property name="configurationUrl" value="classpath:infinispan.xml"/>
    </bean>
  </property>
</bean>

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="direct:start" />
        <idempotentConsumer idempotentRepository="infinispanRepo"> (3)
            <header>MessageID</header>
            <to uri="mock:result" />
        </idempotentConsumer>
    </route>
</camelContext>

<bean id="infinispanRepo" class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedIdempotentRepository" destroy-method="stop">
  <constructor-arg value="idempotent"/> (1)
  <property name="configuration"> (2)
    <bean class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedConfiguration">
      <property name="configurationUrl" value="classpath:infinispan.xml"/>
    </bean>
  </property>
</bean>

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="direct:start" />
        <idempotentConsumer idempotentRepository="infinispanRepo"> (3)
            <header>MessageID</header>
            <to uri="mock:result" />
        </idempotentConsumer>
    </route>
</camelContext>

Copy to Clipboard

Toggle word wrap

Set the name of the cache that will be used by the repository
Configure the repository bean
Set the repository to the route

42.10. Using the Infinispan based aggregation repository
링크 복사

Java Example

InfinispanEmbeddedConfiguration conf = new InfinispanEmbeddedConfiguration(); (1)
conf.setConfigurationUri("classpath:infinispan.xml")

InfinispanEmbeddedAggregationRepository repo = new InfinispanEmbeddedAggregationRepository("aggregation");  (2)
repo.setConfiguration(conf);

context.addRoutes(new RouteBuilder() {
    @Override
    public void configure() {
        from("direct:start")
                .aggregate(header("MessageID"))
                .completionSize(3)
                .aggregationRepository(repo) (3)
                .aggregationStrategy("myStrategy")
                .to("mock:result");
    }
});

InfinispanEmbeddedConfiguration conf = new InfinispanEmbeddedConfiguration(); (1)
conf.setConfigurationUri("classpath:infinispan.xml")

InfinispanEmbeddedAggregationRepository repo = new InfinispanEmbeddedAggregationRepository("aggregation");  (2)
repo.setConfiguration(conf);

context.addRoutes(new RouteBuilder() {
    @Override
    public void configure() {
        from("direct:start")
                .aggregate(header("MessageID"))
                .completionSize(3)
                .aggregationRepository(repo) (3)
                .aggregationStrategy("myStrategy")
                .to("mock:result");
    }
});

Copy to Clipboard

Toggle word wrap

Configure the cache
Create the repository bean
Set the repository to the route

XML Example

<bean id="infinispanRepo" class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedAggregationRepository" destroy-method="stop">
  <constructor-arg value="aggregation"/> (1)
  <property name="configuration"> (2)
    <bean class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedConfiguration">
      <property name="configurationUrl" value="classpath:infinispan.xml"/>
    </bean>
  </property>
</bean>

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="direct:start" />
        <aggregate aggregationStrategy="myStrategy"
                   completionSize="3"
                   aggregationRepository="infinispanRepo"> (3)
            <correlationExpression>
                <header>MessageID</header>
            </correlationExpression>
            <to uri="mock:result"/>
        </aggregate>
    </route>
</camelContext>

<bean id="infinispanRepo" class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedAggregationRepository" destroy-method="stop">
  <constructor-arg value="aggregation"/> (1)
  <property name="configuration"> (2)
    <bean class="org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedConfiguration">
      <property name="configurationUrl" value="classpath:infinispan.xml"/>
    </bean>
  </property>
</bean>

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="direct:start" />
        <aggregate aggregationStrategy="myStrategy"
                   completionSize="3"
                   aggregationRepository="infinispanRepo"> (3)
            <correlationExpression>
                <header>MessageID</header>
            </correlationExpression>
            <to uri="mock:result"/>
        </aggregate>
    </route>
</camelContext>

Copy to Clipboard

Toggle word wrap

Set the name of the cache that will be used by the repository
Configure the repository bean
Set the repository to the route

Note

With the release of Infinispan 11, it is required to set the encoding configuration on any cache created. This is critical for consuming events too. For more information have a look at Data Encoding and MediaTypes in the official Infinispan documentation.

42.11. Spring Boot Auto-Configuration
링크 복사

The component supports 17 options that are listed below.

Expand

Name	Description	Default	Type
camel.component.infinispan-embedded.autowired-enabled	Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.	true	Boolean
camel.component.infinispan-embedded.bridge-error-handler	Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.	false	Boolean
camel.component.infinispan-embedded.cache-container	Specifies the cache Container to connect. The option is a org.infinispan.manager.EmbeddedCacheManager type.		EmbeddedCacheManager
camel.component.infinispan-embedded.cache-container-configuration	The CacheContainer configuration. Used if the cacheContainer is not defined. The option is a org.infinispan.configuration.cache.Configuration type.		Configuration
camel.component.infinispan-embedded.clustered-listener	If true, the listener will be installed for the entire cluster.	false	Boolean
camel.component.infinispan-embedded.configuration	Component configuration. The option is a org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedConfiguration type.		InfinispanEmbeddedConfiguration
camel.component.infinispan-embedded.configuration-uri	An implementation specific URI for the CacheManager.		String
camel.component.infinispan-embedded.custom-listener	Returns the custom listener in use, if provided. The option is a org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedCustomListener type.		InfinispanEmbeddedCustomListener
camel.component.infinispan-embedded.enabled	Whether to enable auto configuration of the infinispan-embedded component. This is enabled by default.		Boolean
camel.component.infinispan-embedded.event-types	Specifies the set of event types to register by the consumer.Multiple event can be separated by comma. The possible event types are: CACHE_ENTRY_ACTIVATED, CACHE_ENTRY_PASSIVATED, CACHE_ENTRY_VISITED, CACHE_ENTRY_LOADED, CACHE_ENTRY_EVICTED, CACHE_ENTRY_CREATED, CACHE_ENTRY_REMOVED, CACHE_ENTRY_MODIFIED, TRANSACTION_COMPLETED, TRANSACTION_REGISTERED, CACHE_ENTRY_INVALIDATED, CACHE_ENTRY_EXPIRED, DATA_REHASHED, TOPOLOGY_CHANGED, PARTITION_STATUS_CHANGED, PERSISTENCE_AVAILABILITY_CHANGED.		String
camel.component.infinispan-embedded.flags	A comma separated list of org.infinispan.context.Flag to be applied by default on each cache invocation.		String
camel.component.infinispan-embedded.lazy-start-producer	Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.	false	Boolean
camel.component.infinispan-embedded.operation	The operation to perform.		InfinispanOperation
camel.component.infinispan-embedded.query-builder	Specifies the query builder. The option is a org.apache.camel.component.infinispan.InfinispanQueryBuilder type.		InfinispanQueryBuilder
camel.component.infinispan-embedded.remapping-function	Set a specific remappingFunction to use in a compute operation. The option is a java.util.function.BiFunction type.		BiFunction
camel.component.infinispan-embedded.result-header	Store the operation result in a header instead of the message body. By default, resultHeader == null and the query result is stored in the message body, any existing content in the message body is discarded. If resultHeader is set, the value is used as the name of the header to store the query result and the original message body is preserved. This value can be overridden by an in message header named: CamelInfinispanOperationResultHeader.		String
camel.component.infinispan-embedded.sync	If true, the consumer will receive notifications synchronously.	true	Boolean

맨 위로 이동

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 42. Infinispan Embedded

42.1. Dependencies
링크 복사

42.2. URI format
링크 복사

42.3. Configuring Options
링크 복사

42.3.1. Configuring Component Options
링크 복사

42.3.2. Configuring Endpoint Options
링크 복사

42.4. Component Options
링크 복사

42.5. Endpoint Options
링크 복사

42.5.1. Path Parameters (1 parameters)
링크 복사

42.5.2. Query Parameters (20 parameters)
링크 복사

42.6. Message Headers
링크 복사

42.7. Camel Operations
링크 복사

42.8. Examples
링크 복사

42.9. Using the Infinispan based idempotent repository
링크 복사

42.10. Using the Infinispan based aggregation repository
링크 복사

42.11. Spring Boot Auto-Configuration
링크 복사

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 42. Infinispan Embedded

42.1. Dependencies링크 복사링크가 클립보드에 복사되었습니다!

42.2. URI format링크 복사링크가 클립보드에 복사되었습니다!

42.3. Configuring Options링크 복사링크가 클립보드에 복사되었습니다!

42.3.1. Configuring Component Options링크 복사링크가 클립보드에 복사되었습니다!

42.3.2. Configuring Endpoint Options링크 복사링크가 클립보드에 복사되었습니다!

42.4. Component Options링크 복사링크가 클립보드에 복사되었습니다!

42.5. Endpoint Options링크 복사링크가 클립보드에 복사되었습니다!

42.5.1. Path Parameters (1 parameters)링크 복사링크가 클립보드에 복사되었습니다!

42.5.2. Query Parameters (20 parameters)링크 복사링크가 클립보드에 복사되었습니다!

42.6. Message Headers링크 복사링크가 클립보드에 복사되었습니다!

42.7. Camel Operations링크 복사링크가 클립보드에 복사되었습니다!

42.8. Examples링크 복사링크가 클립보드에 복사되었습니다!

42.9. Using the Infinispan based idempotent repository링크 복사링크가 클립보드에 복사되었습니다!

42.10. Using the Infinispan based aggregation repository링크 복사링크가 클립보드에 복사되었습니다!

42.11. Spring Boot Auto-Configuration링크 복사링크가 클립보드에 복사되었습니다!

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

42.1. Dependencies
링크 복사

42.2. URI format
링크 복사

42.3. Configuring Options
링크 복사

42.3.1. Configuring Component Options
링크 복사

42.3.2. Configuring Endpoint Options
링크 복사

42.4. Component Options
링크 복사

42.5. Endpoint Options
링크 복사

42.5.1. Path Parameters (1 parameters)
링크 복사

42.5.2. Query Parameters (20 parameters)
링크 복사

42.6. Message Headers
링크 복사

42.7. Camel Operations
링크 복사

42.8. Examples
링크 복사

42.9. Using the Infinispan based idempotent repository
링크 복사

42.10. Using the Infinispan based aggregation repository
링크 복사

42.11. Spring Boot Auto-Configuration
링크 복사