org.springframework.data.redis.connection.RedisConnection.isQueueing()方法的使用及代码示例

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

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

RedisConnection.isQueueing介绍

[英]Indicates whether the connection is in "queue"(or "MULTI") mode or not. When queueing, all commands are postponed until EXEC or DISCARD commands are issued. Since in queueing no results are returned, the connection will return NULL on all operations that interact with the data.
[中]指示连接是否处于“队列”(或“多”)模式。排队时,所有命令都会推迟,直到发出EXEC或DISCARD命令。由于在排队时不会返回任何结果,因此连接将在与数据交互的所有操作上返回NULL。

代码示例

代码示例来源:origin: spring-projects/spring-data-redis

@Override
public boolean isQueueing() {
  return delegate.isQueueing();
}

代码示例来源:origin: spring-projects/spring-data-redis

public <T> T execute(final RedisScript<T> script, final RedisSerializer<?> argsSerializer,
    final RedisSerializer<T> resultSerializer, final List<K> keys, final Object... args) {
  return template.execute((RedisCallback<T>) connection -> {
    final ReturnType returnType = ReturnType.fromJavaType(script.getResultType());
    final byte[][] keysAndArgs = keysAndArgs(argsSerializer, keys, args);
    final int keySize = keys != null ? keys.size() : 0;
    if (connection.isPipelined() || connection.isQueueing()) {
      // We could script load first and then do evalsha to ensure sha is present,
      // but this adds a sha1 to exec/closePipeline results. Instead, just eval
      connection.eval(scriptBytes(script), returnType, keySize, keysAndArgs);
      return null;
    }
    return eval(connection, script, returnType, keySize, keysAndArgs, resultSerializer);
  });
}

代码示例来源:origin: org.springframework.data/spring-data-redis

@Override
public boolean isQueueing() {
  return delegate.isQueueing();
}

代码示例来源:origin: 1991wangliang/tx-lcn

@Override
public boolean isQueueing() {
  return redisConnection.isQueueing();
}

代码示例来源:origin: apache/servicemix-bundles

@Override
public boolean isQueueing() {
  return delegate.isQueueing();
}

代码示例来源:origin: org.springframework.data/spring-data-redis

public <T> T execute(final RedisScript<T> script, final RedisSerializer<?> argsSerializer,
    final RedisSerializer<T> resultSerializer, final List<K> keys, final Object... args) {
  return template.execute((RedisCallback<T>) connection -> {
    final ReturnType returnType = ReturnType.fromJavaType(script.getResultType());
    final byte[][] keysAndArgs = keysAndArgs(argsSerializer, keys, args);
    final int keySize = keys != null ? keys.size() : 0;
    if (connection.isPipelined() || connection.isQueueing()) {
      // We could script load first and then do evalsha to ensure sha is present,
      // but this adds a sha1 to exec/closePipeline results. Instead, just eval
      connection.eval(scriptBytes(script), returnType, keySize, keysAndArgs);
      return null;
    }
    return eval(connection, script, returnType, keySize, keysAndArgs, resultSerializer);
  });
}

代码示例来源:origin: apache/servicemix-bundles

public <T> T execute(final RedisScript<T> script, final RedisSerializer<?> argsSerializer,
    final RedisSerializer<T> resultSerializer, final List<K> keys, final Object... args) {
  return template.execute((RedisCallback<T>) connection -> {
    final ReturnType returnType = ReturnType.fromJavaType(script.getResultType());
    final byte[][] keysAndArgs = keysAndArgs(argsSerializer, keys, args);
    final int keySize = keys != null ? keys.size() : 0;
    if (connection.isPipelined() || connection.isQueueing()) {
      // We could script load first and then do evalsha to ensure sha is present,
      // but this adds a sha1 to exec/closePipeline results. Instead, just eval
      connection.eval(scriptBytes(script), returnType, keySize, keysAndArgs);
      return null;
    }
    return eval(connection, script, returnType, keySize, keysAndArgs, resultSerializer);
  });
}

相关文章

微信公众号

最新文章

更多

RedisConnection类方法