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

RedisConnection.isPipelined介绍

[英]Indicates whether the connection is currently pipelined or not.
[中]指示连接当前是否为管道连接。

代码示例

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

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

代码示例来源：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: spring-projects/spring-data-redis

boolean pipelineStatus = connToUse.isPipelined();
if (pipeline && !pipelineStatus) {
  connToUse.openPipeline();

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

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

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

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

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

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

代码示例来源：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);
  });
}

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

boolean pipelineStatus = connToUse.isPipelined();
if (pipeline && !pipelineStatus) {
  connToUse.openPipeline();

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

boolean pipelineStatus = connToUse.isPipelined();
if (pipeline && !pipelineStatus) {
  connToUse.openPipeline();