org.redisson.Redisson.getCommandExecutor()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(320)

本文整理了Java中org.redisson.Redisson.getCommandExecutor方法的一些代码示例,展示了Redisson.getCommandExecutor的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Redisson.getCommandExecutor方法的具体详情如下:
包路径:org.redisson.Redisson
类名称:Redisson
方法名:getCommandExecutor

Redisson.getCommandExecutor介绍

暂无

代码示例

代码示例来源:origin: redisson/redisson

public RedissonConnection(RedissonClient redisson) {
  super();
  this.redisson = (Redisson) redisson;
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
}

代码示例来源:origin: redisson/redisson

public RedissonConnection(RedissonClient redisson) {
  super();
  this.redisson = (Redisson) redisson;
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
}

代码示例来源:origin: redisson/redisson

public RedissonConnection(RedissonClient redisson) {
  super();
  this.redisson = (Redisson) redisson;
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
}

代码示例来源:origin: redisson/redisson

public RedissonConnection(RedissonClient redisson) {
  super();
  this.redisson = (Redisson) redisson;
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
}

代码示例来源:origin: redisson/redisson

protected void resetConnection() {
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
  index = -1;
  indexToRemove.clear();
}

代码示例来源:origin: redisson/redisson

protected void resetConnection() {
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
  index = -1;
  indexToRemove.clear();
}

代码示例来源:origin: redisson/redisson

protected void resetConnection() {
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
  index = -1;
  indexToRemove.clear();
}

代码示例来源:origin: redisson/redisson

protected void resetConnection() {
  executorService = (CommandAsyncService) this.redisson.getCommandExecutor();
  index = -1;
  indexToRemove.clear();
}

代码示例来源:origin: redisson/redisson

public JCache(JCacheManager cacheManager, Redisson redisson, String name, JCacheConfiguration<K, V> config, boolean hasOwnRedisson) {
  super(redisson.getConfig().getCodec(), redisson.getCommandExecutor(), name);
  
  this.hasOwnRedisson = hasOwnRedisson;
  this.redisson = redisson;
  
  Factory<CacheLoader<K, V>> cacheLoaderFactory = config.getCacheLoaderFactory();
  if (cacheLoaderFactory != null) {
    cacheLoader = cacheLoaderFactory.create();
  }
  Factory<CacheWriter<? super K, ? super V>> cacheWriterFactory = config.getCacheWriterFactory();
  if (config.getCacheWriterFactory() != null) {
    cacheWriter = (CacheWriter<K, V>) cacheWriterFactory.create();
  }
  
  this.cacheManager = cacheManager;
  this.config = config;
  
  redisson.getEvictionScheduler().scheduleJCache(getName(), getTimeoutSetName(), getExpiredChannelName());
  
  for (CacheEntryListenerConfiguration<K, V> listenerConfig : config.getCacheEntryListenerConfigurations()) {
    registerCacheEntryListener(listenerConfig, false);
  }
}

代码示例来源:origin: redisson/redisson

public JCache(JCacheManager cacheManager, Redisson redisson, String name, JCacheConfiguration<K, V> config, boolean hasOwnRedisson) {
  super(redisson.getConfig().getCodec(), redisson.getCommandExecutor(), name);
  
  this.hasOwnRedisson = hasOwnRedisson;
  this.redisson = redisson;
  
  Factory<CacheLoader<K, V>> cacheLoaderFactory = config.getCacheLoaderFactory();
  if (cacheLoaderFactory != null) {
    cacheLoader = cacheLoaderFactory.create();
  }
  Factory<CacheWriter<? super K, ? super V>> cacheWriterFactory = config.getCacheWriterFactory();
  if (config.getCacheWriterFactory() != null) {
    cacheWriter = (CacheWriter<K, V>) cacheWriterFactory.create();
  }
  
  this.cacheManager = cacheManager;
  this.config = config;
  
  redisson.getEvictionScheduler().scheduleJCache(getName(), getTimeoutSetName(), getExpiredChannelName());
  
  for (CacheEntryListenerConfiguration<K, V> listenerConfig : config.getCacheEntryListenerConfigurations()) {
    registerCacheEntryListener(listenerConfig, false);
  }
}

代码示例来源:origin: org.redisson/redisson

public JCache(JCacheManager cacheManager, Redisson redisson, String name, JCacheConfiguration<K, V> config, boolean hasOwnRedisson) {
  super(redisson.getConfig().getCodec(), redisson.getCommandExecutor(), name);
  
  this.hasOwnRedisson = hasOwnRedisson;
  this.redisson = redisson;
  
  Factory<CacheLoader<K, V>> cacheLoaderFactory = config.getCacheLoaderFactory();
  if (cacheLoaderFactory != null) {
    cacheLoader = cacheLoaderFactory.create();
  }
  Factory<CacheWriter<? super K, ? super V>> cacheWriterFactory = config.getCacheWriterFactory();
  if (config.getCacheWriterFactory() != null) {
    cacheWriter = (CacheWriter<K, V>) cacheWriterFactory.create();
  }
  
  this.cacheManager = cacheManager;
  this.config = config;
  
  redisson.getEvictionScheduler().scheduleJCache(getName(), getTimeoutSetName(), getExpiredChannelName());
  
  for (CacheEntryListenerConfiguration<K, V> listenerConfig : config.getCacheEntryListenerConfigurations()) {
    registerCacheEntryListener(listenerConfig, false);
  }
}

相关文章