Infinispan Cluster Service
JVM since3.32.0 Native since3.32.0
Provides an Infinispan implementation of the Camel Cluster Service SPI
Maven coordinates
Or add the coordinates to your existing project:
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-infinispan-cluster-service</artifactId>
</dependency>Check the User guide for more information about writing Camel Quarkus applications.
Additional Camel Quarkus configuration
Having only a single consumer in a cluster consuming from a given endpoint
When the same route is deployed on multiple JVMs, it could be interesting to use this extension in conjunction with the Master one. In such a setup, a single consumer will be active at a time across the whole camel master namespace.
For instance, having the route below deployed on multiple JVMs:
from("master:ns:timer:test?period=100")
.log("Timer invoked on a single JVM at a time");As a result, a single consumer will be active across the ns camel master namespace. It means that, at a given time, only a single timer will generate exchanges across all JVMs. In other words, messages will be logged every 100ms on a single JVM at a time.
Infinispan Configuration
You can configure the Infinispan client with the various quarkus.camel.cluster.infinispan configuration options in `application.properties.
quarkus.camel.cluster.infinispan.hosts=localhost:11222
quarkus.camel.cluster.infinispan.username=admin
quarkus.camel.cluster.infinispan.password=2s3cr3t
# Optional additional configuration properties
quarkus.camel.cluster.infinispan.configuration-properties."infinispan.client.hotrod.client_intelligence" = BASIC
quarkus.camel.cluster.infinispan.configuration-properties."infinispan.client.hotrod.connect_timeout" = 5000| Configuration property | Type | Default |
|---|---|---|
Whether an Infinispan Cluster Service should be automatically configured according to 'quarkus.camel.cluster.infinispan.*' configurations. |
|
|
The cluster service ID. |
| |
The service lookup order/priority. |
| |
The custom attributes associated to the service. |
| |
The Infinispan configuration URI. Can be used to specify a custom Infinispan configuration file. |
| |
The Infinispan server hosts (e.g., "localhost:11222"). |
| |
Enable secure connections to an Infinispan server. |
| |
Username for authentication with the Infinispan server. |
| |
Password for authentication with the Infinispan server. |
| |
SASL mechanism for authentication (e.g., DIGEST-MD5, PLAIN, SCRAM-SHA-256). |
| |
Security realm for authentication. |
| |
Security server name for authentication. |
| |
Additional configuration properties for the Infinispan client. |
| |
Lifespan for entries in the cluster view cache. |
|
|
Time unit for lifespan (e.g., SECONDS, MINUTES, HOURS). |
|
|
Configuration property fixed at build time. All other configuration properties are overridable at runtime.