import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@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();
      }
    }
  });
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@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();
  }
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@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();
      }
    }
  });
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@Override
public void monitor(JedisMonitor jedisMonitor) {
	redis.clients.jedis.Jedis delegate = pool.getResource();
	try {
		delegate.monitor(jedisMonitor);
	} finally {
		pool.returnResource(delegate);
	}
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
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;
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@Override
public void monitor(JedisMonitor jedisMonitor) {
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@Override public void monitor(JedisMonitor jedisMonitor) {
    throw new FakeJedisNotImplementedException();
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@Override
public void monitor(JedisMonitor jedisMonitor) {
	super.monitor(jedisMonitor);
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
@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.");
	}
}
 

import redis.clients.jedis.JedisMonitor; //导入依赖的package包/类
/**
 * @param jedisMonitor
 * @see redis.clients.jedis.BinaryJedis#monitor(redis.clients.jedis.JedisMonitor)
 */
public abstract void monitor(JedisMonitor jedisMonitor);