本文整理汇总了Java中org.infinispan.commons.api.BasicCache类的典型用法代码示例。如果您正苦于以下问题：Java BasicCache类的具体用法？Java BasicCache怎么用？Java BasicCache使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
BasicCache类属于org.infinispan.commons.api包，在下文中一共展示了BasicCache类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getCache
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
private BasicCache<Object, Boolean> getCache() {
if (cache == null) {
// By default, previously existing values for java.util.Map operations
// are not returned for remote caches but idempotent repository needs
// them so force it.
if (InfinispanUtil.isRemote(cacheContainer)) {
RemoteCacheManager manager = InfinispanUtil.asRemote(cacheContainer);
cache = cacheName != null
? manager.getCache(cacheName, true)
: manager.getCache(true);
} else {
cache = cacheName != null
? cacheContainer.getCache(cacheName)
: cacheContainer.getCache();
}
}
return cache;
}
开发者ID:HydAu，项目名称:Camel，代码行数:20，代码来源:InfinispanIdempotentRepository.java
示例2: execute
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@Override
void execute(InfinispanConfiguration configuration, BasicCache<Object, Object> cache, Message message) {
Object result;
if (hasLifespan(message)) {
long lifespan = message.getHeader(InfinispanConstants.LIFESPAN_TIME, long.class);
TimeUnit timeUnit = message.getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT, TimeUnit.class);
if (hasMaxIdleTime(message)) {
long maxIdle = message.getHeader(InfinispanConstants.MAX_IDLE_TIME, long.class);
TimeUnit maxIdleTimeUnit = message.getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, TimeUnit.class);
result = cache.put(getKey(message), getValue(message), lifespan, timeUnit, maxIdle, maxIdleTimeUnit);
} else {
result = cache.put(getKey(message), getValue(message), lifespan, timeUnit);
}
} else {
result = cache.put(getKey(message), getValue(message));
}
setResult(result, message);
}
开发者ID:HydAu，项目名称:Camel，代码行数:19，代码来源:InfinispanOperation.java
示例3: embeddedCacheWithFlagsTest
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@Test
public void embeddedCacheWithFlagsTest() throws Exception {
InfinispanConfiguration configuration = new InfinispanConfiguration();
configuration.setHost("localhost");
configuration.setCacheName("misc_cache");
configuration.setCacheContainer(new DefaultCacheManager(true));
configuration.setFlags(
org.infinispan.context.Flag.SKIP_CACHE_LOAD,
org.infinispan.context.Flag.SKIP_CACHE_STORE
);
InfinispanManager manager = new InfinispanManager(configuration);
manager.start();
BasicCache<Object, Object> cache = manager.getCache();
assertNotNull(cache);
assertTrue(cache instanceof DecoratedCache);
DecoratedCache<Object, Object> decoratedCache = (DecoratedCache<Object, Object>)cache;
assertTrue(decoratedCache.getFlags().contains(org.infinispan.context.Flag.SKIP_CACHE_LOAD));
assertTrue(decoratedCache.getFlags().contains(org.infinispan.context.Flag.SKIP_CACHE_STORE));
manager.getCacheContainer().stop();
manager.stop();
}
开发者ID:HydAu，项目名称:Camel，代码行数:26，代码来源:InfinispanConfigurationTestIT.java
示例4: remoteCacheWithoutProperties
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@Test
public void remoteCacheWithoutProperties() throws Exception {
InfinispanConfiguration configuration = new InfinispanConfiguration();
configuration.setHost("localhost");
configuration.setCacheName("misc_cache");
InfinispanManager manager = new InfinispanManager(configuration);
manager.start();
BasicCache<Object, Object> cache = manager.getCache();
assertNotNull(cache);
assertTrue(cache instanceof RemoteCache);
RemoteCache<Object, Object> remoteCache = InfinispanUtil.asRemote(cache);
String key = UUID.randomUUID().toString();
assertNull(remoteCache.put(key, "val1"));
assertNull(remoteCache.put(key, "val2"));
manager.stop();
}
开发者ID:HydAu，项目名称:Camel，代码行数:22，代码来源:InfinispanConfigurationTestIT.java
示例5: remoteCacheWithPropertiesTest
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@Test
public void remoteCacheWithPropertiesTest() throws Exception {
InfinispanConfiguration configuration = new InfinispanConfiguration();
configuration.setHost("localhost");
configuration.setCacheName("misc_cache");
configuration.setConfigurationUri("infinispan/client.properties");
InfinispanManager manager = new InfinispanManager(configuration);
manager.start();
BasicCache<Object, Object> cache = manager.getCache();
assertNotNull(cache);
assertTrue(cache instanceof RemoteCache);
String key = UUID.randomUUID().toString();
assertNull(cache.put(key, "val1"));
assertNotNull(cache.put(key, "val2"));
manager.stop();
}
开发者ID:HydAu，项目名称:Camel，代码行数:21，代码来源:InfinispanConfigurationTestIT.java
示例6: loadEntries
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public static void loadEntries(BasicCache<Long, MoneyTransfert> cache,String[] inputFileNames) throws IOException {
StreamFactory factory = StreamFactory.newInstance();
factory.loadResource("mapping.xml");
Unmarshaller unmarshaller = factory.createUnmarshaller("MoneyTransferStream");
String record;
// Read Transactions and put in cache
for (String inputFile : inputFileNames) {
record = FileUtils.getContentsAsString(new File(INPUT_DIR + inputFile));
MoneyTransfert mt = (MoneyTransfert) unmarshaller.unmarshal(record);
cache.put(mt.getId(), mt);
}
}
开发者ID:PacktPublishing，项目名称:JBoss-Developers-Guide，代码行数:16，代码来源:BeosBankCacheUtils.java
示例7: isEmbedded
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public static <K, V> boolean isEmbedded(BasicCache<K, V> cache) {
try {
return cache instanceof Cache;
} catch (Throwable e) {
return false;
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:8，代码来源:InfinispanUtil.java
示例8: isRemote
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public static <K, V> boolean isRemote(BasicCache<K, V> cache) {
try {
return cache instanceof RemoteCache;
} catch (Throwable e) {
return false;
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:8，代码来源:InfinispanUtil.java
示例9: ignoreReturnValuesCache
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public static <K, V> BasicCache<K, V> ignoreReturnValuesCache(BasicCache<K, V> cache) {
if (isEmbedded(cache)) {
return ((Cache<K, V>) cache).getAdvancedCache().withFlags(Flag.IGNORE_RETURN_VALUES);
} else {
return cache;
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:8，代码来源:InfinispanUtil.java
示例10: process
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public static void process(Exchange exchange, InfinispanConfiguration configuration, BasicCache<Object, Object> cache) {
final Message in = exchange.getIn();
Operation operation = getOperation(in, configuration);
operation.execute(
configuration,
exchange.getIn().getHeader(InfinispanConstants.IGNORE_RETURN_VALUES) != null
? cache
: InfinispanUtil.ignoreReturnValuesCache(cache),
in
);
}
开发者ID:HydAu，项目名称:Camel，代码行数:13，代码来源:InfinispanOperation.java
示例11: getQuery
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
Query getQuery(InfinispanConfiguration configuration, BasicCache<Object, Object> cache, Message message) {
if (InfinispanUtil.isRemote(cache)) {
return InfinispanRemoteOperation.buildQuery(configuration, cache, message);
} else {
return null;
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:9，代码来源:InfinispanOperation.java
示例12: buildQuery
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public static Query buildQuery(InfinispanConfiguration configuration, BasicCache<Object, Object> cache, Message message) {
InfinispanQueryBuilder queryBuilder = message.getHeader(InfinispanConstants.QUERY_BUILDER, InfinispanQueryBuilder.class);
if (queryBuilder == null) {
queryBuilder = configuration.getQueryBuilder();
}
return buildQuery(queryBuilder, cache);
}
开发者ID:HydAu，项目名称:Camel，代码行数:9，代码来源:InfinispanRemoteOperation.java
示例13: getCache
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public BasicCache<Object, Object> getCache(String cacheName) {
if (cacheName == null) {
cacheName = configuration.getCacheName();
}
LOGGER.trace("Cache[{}]", cacheName);
BasicCache<Object, Object> cache = InfinispanUtil.getCache(cacheContainer, cacheName);
if (configuration.hasFlags() && InfinispanUtil.isEmbedded(cache)) {
cache = new DecoratedCache(InfinispanUtil.asAdvanced(cache), configuration.getFlags());
}
return cache;
}
开发者ID:HydAu，项目名称:Camel，代码行数:15，代码来源:InfinispanManager.java
示例14: getCustomListLocalCache
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@Produces
@ApplicationScoped
@SinkitCache(SinkitCacheName.custom_lists_local_cache)
public BasicCache<String, List<CustomList>> getCustomListLocalCache() {
if (localCacheManager == null) {
throw new IllegalArgumentException("Manager must not be null.");
}
log.log(Level.INFO, "getCustomListLocalCache called.");
return localCacheManager.getCache(SinkitCacheName.custom_lists_local_cache.toString());
}
开发者ID:whalebone，项目名称:sinkit-core，代码行数:11，代码来源:MyCacheManagerProvider.java
示例15: getRuleLocalCache
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@Produces
@ApplicationScoped
@SinkitCache(SinkitCacheName.rules_local_cache)
public BasicCache<String, List<Rule>> getRuleLocalCache() {
if (localCacheManager == null) {
throw new IllegalArgumentException("Manager must not be null.");
}
log.log(Level.INFO, "getRuleLocalCache called.");
return localCacheManager.getCache(SinkitCacheName.rules_local_cache.toString());
}
开发者ID:whalebone，项目名称:sinkit-core，代码行数:11，代码来源:MyCacheManagerProvider.java
示例16: getCache
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public BasicCache<?,?> getCache(String cacheName) {
if (cacheName == null) {
return ecm.getCache();
}
return ecm.getCache(cacheName);
}
开发者ID:kenweezy，项目名称:teiid，代码行数:9，代码来源:AbstractInfinispanManagedConnectionFactory.java
示例17: ExpiringSessionMap
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public ExpiringSessionMap(BasicCache<String, ExpiringSession> cache) {
this.cache = cache;
}
开发者ID:kazuhira-r，项目名称:spring-session-infinispan，代码行数:4，代码来源:ExpiringSessionMap.java
示例18: ShiroCache
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
public ShiroCache(final BasicCache<K, V> nativeCache) {
Assert.notNull(nativeCache, "A non-null Infinispan cache implementation is required");
this.nativeCache = nativeCache;
}
开发者ID:xiangxik，项目名称:java-platform，代码行数:5，代码来源:ShiroCache.java
示例19: asEmbedded
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public static <K, V> Cache<K, V> asEmbedded(BasicCache<K, V> cache) {
return Cache.class.cast(cache);
}
开发者ID:HydAu，项目名称:Camel，代码行数:5，代码来源:InfinispanUtil.java
示例20: asRemote
import org.infinispan.commons.api.BasicCache; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public static <K, V> RemoteCache<K, V> asRemote(BasicCache<K, V> cache) {
return RemoteCache.class.cast(cache);
}
开发者ID:HydAu，项目名称:Camel，代码行数:5，代码来源:InfinispanUtil.java
注：本文中的org.infinispan.commons.api.BasicCache类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论