api/java/src/main/java/com/navercorp/redis/cluster/pipeline/RedisClusterPipeline.java
public void sync() {
        if (this.client == null) {
            return;
        }

        List<Object> unformatted = null;
        try {
            unformatted = this.client.getAll();
        } catch (Exception e) {
            this.brokenResource = true;
            throw new GatewayException("gateway=" + this.server + ", connect=" + this.redis.connectInfo(), e);
        }

        if (unformatted == null) {
            return;
        }

        for (Object o : unformatted) {
            try {
                generateResponse(o);
            } catch (Exception ignored) {
            }
        }
    }
public void sync() {
        if (this.client == null) {
            return;
        }

        List<Object> unformatted = null;
        try {
            unformatted = this.client.getAll();
        } catch (Exception e) {
            this.brokenResource = true;
            throw new GatewayException("gateway=" + this.server + ", connect=" + this.redis.connectInfo(), e);
        }

        if (unformatted == null) {
            return;
        }

        for (Object o : unformatted) {
            try {
                generateResponse(o);
            } catch (Exception ignored) {
            }
        }
    }
public void sync ( ) { if ( this . client == null ) { return ; } List < Object > unformatted = null ; try { unformatted = this . client . getAll ( ) ; } catch ( Exception e ) { this . brokenResource = true ; throw new GatewayException ( "gateway=" + this . server + ", connect=" + this . redis . connectInfo ( ) , e ) ; } if ( unformatted == null ) { return ; } for ( Object o : unformatted ) { try { generateResponse ( o ) ; } catch ( Exception ignored ) { } } }
Synchronize pipeline by reading all responses. This operation close the
pipeline. In order to get return values from pipelined commands, capture
the different Response&lt;?&gt; of the commands you execute.
Synchronize pipeline by reading all responses . This operation close the pipeline . In order to get return values from pipelined commands capture the different Response&lt ; ?&gt ; of the commands you execute .