如何让 Infinispan 与骆驼一起工作

Question

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.infinispan.InfinispanConstants;
import org.apache.camel.component.jackson.JacksonDataFormat;
import org.apache.camel.model.dataformat.JsonLibrary;
import uk.co.sammy.model.Collection;

public class InfinispanRoute extends RouteBuilder {

    private JacksonDataFormat json = new JacksonDataFormat(Collection.class);

    @Override
    public void configure() throws Exception {
        from("file:src/data?noop=true&include=.*.json")
                .choice()
                .when()
                .jsonpath("$..CustInfo[?(@.firstName == 'Sammy')]").unmarshal(json)
                .log("Got customer data for ${body.custInfo.firstName}")
                .setHeader(InfinispanConstants.OPERATION, constant(InfinispanConstants.PUT_IF_ABSENT))
                .setHeader(InfinispanConstants.KEY, simple("${body.custInfo.firstName}"))
                .to("infinispan://localhost")
                .marshal().json(JsonLibrary.Jackson)
                .to("activemq:queue:incomingApplication", "activemq:queue:customerDetails");

        from("activemq:queue:incomingApplication")
                .setHeader(InfinispanConstants.OPERATION, constant(InfinispanConstants.GET))
                .setHeader(InfinispanConstants.KEY, constant("${body.custInfo.firstName}"))
                .to("infinispan://foo?cacheName=localCache")
                .setBody(simple("${header.CamelInfinispanOperationResult}"))
                .to("activemq:output");
    }
}

我的 pom.xml 如下所示

<properties>
        <activemq.version>5.14.1</activemq.version>
        <camel.version>2.18.0</camel.version>
        <infinispan.version>8.3.0.Final-redhat-1</infinispan.version>
        <camel-jbossdatagrid.version>6.6.1.Final-redhat-1</camel-jbossdatagrid.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-core</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-jackson</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-jsonpath</artifactId>
            <version>${camel.version}</version>
        </dependency>
        <dependency>
            <groupId>org.infinispan</groupId>
            <artifactId>infinispan-embedded</artifactId>
            <version>${infinispan.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-jbossdatagrid</artifactId>
            <version>${camel-jbossdatagrid.version}</version>
        </dependency>

        <!--ActiveMQ -->
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-camel</artifactId>
            <version>${activemq.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-pool</artifactId>
            <version>${activemq.version}</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.10</version>
        </dependency>
        <dependency>
            <groupId>org.ow2.asm</groupId>
            <artifactId>asm-all</artifactId>
            <version>5.1</version>
        </dependency>
    </dependencies>

    <repositories>
        <repository>
            <id>fuse-release</id>
            <name>jboss Release Repository</name>
            <releases>
                <updatePolicy>never</updatePolicy>
            </releases>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
            <url>http://repo.fusesource.com/nexus/content/groups/public/</url>
        </repository>
    </repositories>
</project>

我已经尝试了三天让这个简单的示例代码使用 REdhat 入门指南与 Infinispan 一起工作，并将快速入门 zip 下载到运行但仍然无法工作！我不断收到 Spring JMS 的错误“无法连接到 foo:11222”或“池未打开”然后关于混合 Uber 和 Jars 版本的警告。我开始使用 ehcache，这很难实现，因为展示如何存储、检索和清除来自 rest 调用等的缓存的简单示例有限。现在，我需要它来工作，以便我可以轻松地将它迁移到 Openshift，但是，仍然行不通！每次重新启动项目时，都会出现不同的错误。请任何帮助逐步设置 Infinispan 以使用我的上述代码工作将不胜感激。谢谢大家！

P.S：我已经通读了 Redhat 数据网格入门页面并按照他们的说明进行操作，然后才将其作为最后的手段！！！

Answer 1

使用 "infinispan://localhost" uri 格式将尝试连接到 Infinispan 服务器。要使用嵌入式缓存，您应该使用 "infinispan://?cacheName=localCache"

Answer 2

我发现您提供的示例中存在一些错误：

第一条路线：

您应该使用 InfinispanConstants.VALUE

第二条路线：

您应该使用与第一个路由相同的缓存（即相同的缓存名称）
你应该使用简单的设置 InfinispanConstants.KEY

如何让 Infinispan 与骆驼一起工作

How to make Infinispan work with camel

java

caching

intellij-idea

apache-camel

infinispan