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

Class redis.clients.jedis.ShardedJedisPipeline

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

redis.clients.jedis.ShardedJedisPipeline.sync()
Syncronize pipeline by reading all responses. This operation closes the pipeline. In order to get return values from pipelined commands, capture the different Response<?> of the commands you execute.

  Response<Map<String, String>> hgetAll = p.hgetAll("hash");
  p.sadd("set", "foo");
  Response<Set<String>> smembers = p.smembers("set");
  Response<Set<Tuple>> zrangeWithScores = p.zrangeWithScores("zset", 0,
    -1);
  p.sync();


  assertEquals("foo", string.get());
  assertEquals(Long.valueOf(1), del.get());
  assertNull(emptyString.get());
  assertEquals("foo", list.get());

View Full Code Here

  jedis.set("string", "foo");


  ShardedJedisPipeline p = jedis.pipelined();
  Response<String> string = p.get("string");
  string.get();
  p.sync();
    }


    @Test
    public void canRetrieveUnsetKey() {
  ShardedJedisPipeline p = jedis.pipelined();

View Full Code Here


    @Test
    public void canRetrieveUnsetKey() {
  ShardedJedisPipeline p = jedis.pipelined();
  Response<String> shouldNotExist = p.get(UUID.randomUUID().toString());
  p.sync();
  assertNull(shouldNotExist.get());
    }
}

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.