@Test public void monitor() { new Thread(new Runnable() { public void run() { try { // sleep 100ms to make sure that monitor thread runs first Thread.sleep(100); } catch (InterruptedException e) { } Jedis j = new Jedis("localhost"); j.auth("foobared"); for (int i = 0; i < 5; i++) { j.incr("foobared"); } j.disconnect(); } }).start(); jedis.monitor(new JedisMonitor() { private int count = 0; public void onCommand(String command) { if (command.contains("INCR")) { count++; } if (count == 5) { client.disconnect(); } } }); }
@Override public void monitor(JedisMonitor jedisMonitor) { Span span = helper.buildSpan("monitor"); try { super.monitor(jedisMonitor); } catch (Exception e) { onError(e, span); throw e; } finally { span.finish(); } }
@Test public void monitor() { new Thread(new Runnable() { @Override public void run() { try { // sleep 100ms to make sure that monitor thread runs first Thread.sleep(100); } catch (InterruptedException e) { } Jedis j = new Jedis("localhost"); j.auth("foobared"); for (int i = 0; i < 5; i++) { j.incr("foobared"); } j.disconnect(); } }).start(); jedis.monitor(new JedisMonitor() { private int count = 0; @Override public void onCommand(String command) { if (command.contains("INCR")) { count++; } if (count == 5) { client.disconnect(); } } }); }
@Override public void monitor(JedisMonitor jedisMonitor) { redis.clients.jedis.Jedis delegate = pool.getResource(); try { delegate.monitor(jedisMonitor); } finally { pool.returnResource(delegate); } }
private String monitor0(Jedis j, final RedisMonitorHandler handler) { JedisMonitor jm = new JedisMonitor() { @Override public void onCommand(String command) { handler.onCommand(command); } }; j.monitor(jm); return OK; }
@Override public void monitor(JedisMonitor jedisMonitor) { }
@Override public void monitor(JedisMonitor jedisMonitor) { throw new FakeJedisNotImplementedException(); }
@Override public void monitor(JedisMonitor jedisMonitor) { super.monitor(jedisMonitor); }
@Override public void run() { if (log.isDebugEnabled()) log.debug("Starting monitor."); try { this.getMonitorJedis().monitor(new JedisMonitor() { @Override public void onCommand(String command) { if (log.isDebugEnabled()) log.debug(command); JedisMonitorThread.this.logBuffer.append(command + "\n"); } }); } catch (Exception ex) { if (log.isDebugEnabled()) log.debug("Stopping monitor."); } }
/** * @param jedisMonitor * @see redis.clients.jedis.BinaryJedis#monitor(redis.clients.jedis.JedisMonitor) */ public abstract void monitor(JedisMonitor jedisMonitor);