This is an automated email from the ASF dual-hosted git repository.
fmariani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot-examples.git
The following commit(s) were added to refs/heads/main by this push:
new 5fbb187 infinispan: uses Camel component configuration
5fbb187 is described below
commit 5fbb187f028c9e31a73785278bca4cfd71fba0c0
Author: Marco Carletti <[email protected]>
AuthorDate: Wed Feb 26 08:49:18 2025 +0100
infinispan: uses Camel component configuration
---
.../example/springboot/infinispan/Application.java | 106 ---------------------
.../infinispan/CamelInfinispanRoute.java | 4 +-
.../src/main/resources/application.properties | 10 +-
3 files changed, 7 insertions(+), 113 deletions(-)
diff --git
a/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/Application.java
b/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/Application.java
index 3cd15a1..82ebad5 100644
---
a/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/Application.java
+++
b/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/Application.java
@@ -16,125 +16,19 @@
*/
package org.apache.camel.example.springboot.infinispan;
-import org.apache.camel.component.infinispan.remote.InfinispanRemoteComponent;
-import
org.apache.camel.component.infinispan.remote.InfinispanRemoteConfiguration;
-
-import org.infinispan.client.hotrod.RemoteCacheManager;
-import org.infinispan.client.hotrod.configuration.ConfigurationBuilder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.testcontainers.shaded.org.apache.commons.lang3.SystemUtils;
-
-import java.util.Properties;
// CHECKSTYLE:OFF
@SpringBootApplication
public class Application {
- private static final Logger LOG =
LoggerFactory.getLogger(Application.class);
-
/**
* Main method to start the application.
*/
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
-
- @Configuration
- @ConfigurationProperties(prefix = "infinispan")
- public class InfinispanConfiguration {
-
- private String host;
-
- private Integer port;
-
- private String username;
-
- private String password;
-
- private String serverName;
-
- protected ConfigurationBuilder getConfiguration() {
- ConfigurationBuilder clientBuilder = new ConfigurationBuilder();
-
- clientBuilder.forceReturnValues(true);
-
-
- clientBuilder.addServer().host(getHost()).port(getPort());
-
- // add security info
-
clientBuilder.security().authentication().username(getUsername()).password(getPassword())
-
.serverName(getServerName()).saslMechanism("DIGEST-MD5").realm("default");
- if (SystemUtils.IS_OS_MAC) {
- Properties properties = new Properties();
- properties.put("infinispan.client.hotrod.client_intelligence",
"BASIC");
- clientBuilder.withProperties(properties);
- }
-
- return clientBuilder;
- }
-
- @Bean(name = "infinispanRemoteComponent")
- public InfinispanRemoteComponent infinispanRemoteComponent() {
- InfinispanRemoteConfiguration infinispanRemoteConfiguration = new
InfinispanRemoteConfiguration();
- infinispanRemoteConfiguration.setHosts(getHost() + ":" +
getPort());
- infinispanRemoteConfiguration.setUsername(getUsername());
- infinispanRemoteConfiguration.setPassword(getPassword());
-
- RemoteCacheManager cacheContainer = new
RemoteCacheManager(getConfiguration().build());
- infinispanRemoteConfiguration.setCacheContainer(cacheContainer);
-
- InfinispanRemoteComponent component = new
InfinispanRemoteComponent();
- component.setConfiguration(infinispanRemoteConfiguration);
- return component;
- }
-
- public String getHost() {
- return host;
- }
-
- public void setHost(final String host) {
- this.host = host;
- }
-
- public Integer getPort() {
- return port;
- }
-
- public void setPort(final Integer port) {
- this.port = port;
- }
-
- public String getUsername() {
- return username;
- }
-
- public void setUsername(final String username) {
- this.username = username;
- }
-
- public String getPassword() {
- return password;
- }
-
- public void setPassword(final String password) {
- this.password = password;
- }
-
- public String getServerName() {
- return serverName;
- }
-
- public void setServerName(final String serverName) {
- this.serverName = serverName;
- }
- }
-
}
// CHECKSTYLE:ON
diff --git
a/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
b/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
index c69347c..8c68150 100644
---
a/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
+++
b/infinispan/src/main/java/org/apache/camel/example/springboot/infinispan/CamelInfinispanRoute.java
@@ -38,10 +38,10 @@ public class CamelInfinispanRoute extends RouteBuilder {
.setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.PUT)
.setHeader(InfinispanConstants.KEY).constant("1")
.setHeader(InfinispanConstants.VALUE).constant("test")
- .to("infinispanRemoteComponent://default")
+ .to("infinispan://default")
.setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.GET)
.setHeader(InfinispanConstants.KEY).constant("1")
- .to("infinispanRemoteComponent://default")
+ .to("infinispan://default")
.log("Received body: ${body}");
}
diff --git a/infinispan/src/main/resources/application.properties
b/infinispan/src/main/resources/application.properties
index b5bdda2..2f382d7 100644
--- a/infinispan/src/main/resources/application.properties
+++ b/infinispan/src/main/resources/application.properties
@@ -17,9 +17,9 @@
camel.springboot.name=Infinispan
camel.springboot.main-run-controller=true
-infinispan.host=localhost
-infinispan.port=11222
-infinispan.username=admin
-infinispan.password=password
-infinispan.server-name=infinispan
+camel.component.infinispan.hosts=localhost:11222
+camel.component.infinispan.username=admin
+camel.component.infinispan.password=password
+camel.component.infinispan.security-server-name=infinispan
+camel.component.infinispan.secure=true
