29.7. 例子
将键/值放入命名缓存中：
from("direct:start") .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.PUT) (1) .setHeader(InfinispanConstants.KEY).constant("123") (2) .to("infinispan:myCacheName&cacheContainer=#cacheContainer"); (3)其中,
- 1 - 设置要执行的操作
- 2 - 设置用于识别缓存中元素的键
3 - 使用 registry 中配置的 cache manager
cacheContainer将元素放在名为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");
其中,
- 1 - 设置条目的生命周期
- 2 - 为生命周期设置时间单位
查询
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") ;
注意
域对象的 .proto 描述符必须注册到远程 Data Grid 服务器，请参阅官方 Infinispan 文档中的 Remote Query 示例。
自定义 Listeners
from("infinispan://?cacheContainer=#cacheManager&customListener=#myCustomListener")
.to("mock:result");
myCustomListener 实例必须存在，Camel 应该可以从 Registry 中查找它。建议用户扩展 org.apache.camel.component.infinispan.remote.InfinispanRemoteCustomListener 类，并使用 @ClientListener 注解生成的类，该类可以在软件包 org.infinispan.client.hotrod.annotation 中找到。
