Package redis.clients.jedis

Examples of redis.clients.jedis.Jedis.hmset()


  }
 
  public void record(String meetingId, Map<String, String> event) {   
    Jedis jedis = new Jedis(host, port);
    Long msgid = jedis.incr("global:nextRecordedMsgId");
    jedis.hmset("recording:" + meetingId + COLON + msgid, event);
    jedis.rpush("meeting:" + meetingId + COLON + "recordings", msgid.toString());           
  }
}
View Full Code Here


  @Override
  public void record(String session, RecordEvent message) {   
    Jedis jedis = redisPool.getResource();
    try {
      Long msgid = jedis.incr("global:nextRecordedMsgId");
      jedis.hmset("recording" + COLON + session + COLON + msgid, message.toMap());
      jedis.rpush("meeting" + COLON + session + COLON + "recordings", msgid.toString());
    } finally {
      redisPool.returnResource(jedis);
    }           
  }
View Full Code Here

  }
 
  private void record(String session, RecordEvent message) {
    Jedis jedis = new Jedis(host, port);
    Long msgid = jedis.incr("global:nextRecordedMsgId");
    jedis.hmset("recording" + COLON + session + COLON + msgid, message.toMap());
    jedis.rpush("meeting" + COLON + session + COLON + "recordings", msgid.toString());           
  }
 
  @Override
  public void notify(RecordEvent event) {
View Full Code Here

    public void hmSet(String key, Map<String, Serializable> values)
            throws Exception {
        Jedis jedis = null;
        try {
            jedis = this.jedisPool.getResource();
            jedis.hmset(SafeEncoder.encode(key), encodeMap(values));
            LOG.info("hmSet key:" + key + " field:" + values.keySet());
        } catch (Exception e) {
            LOG.error(e.getMessage(), e);
            this.jedisPool.returnBrokenResource(jedis);
            throw e;
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.