Examples of redis.clients.jedis.ShardedJedisPipeline.syncAndReturnAll()

Class redis.clients.jedis.ShardedJedisPipeline

Examples of redis.clients.jedis.ShardedJedisPipeline.syncAndReturnAll()

redis.clients.jedis.ShardedJedisPipeline.syncAndReturnAll()
Syncronize pipeline by reading all responses. This operation closes the pipeline. Whenever possible try to avoid using this version and use ShardedJedisPipeline.sync() as it won't go through all the responses and generate the right response type (usually it is a waste of time). @return A list of all the responses in the order you executed them.

    @Test
    public void pipeline() throws UnsupportedEncodingException {
  ShardedJedisPipeline p = jedis.pipelined();
  p.set("foo", "bar");
  p.get("foo");
  List<Object> results = p.syncAndReturnAll();


  assertEquals(2, results.size());
  assertEquals("OK", results.get(0));
  assertEquals("bar", results.get(1));
    }

View Full Code Here

  jedis.resetState();


  pipeline = jedis.pipelined();
  pipeline.incr("pipelined");
  pipeline.incr("pipelined2");
  List<Object> results = pipeline.syncAndReturnAll();


  assertEquals(2, results.size());
  pool.returnResource(jedis);
  pool.destroy();
    }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.