Implemented MONITOR

src/main/java/redis/clients/jedis/Client.java

@@ -535,4 +535,8 @@ public void shutdown() {
     public void info() {
 	sendCommand("INFO");
     }
+
+    public void monitor() {
+	sendCommand("MONITOR");
+    }
 }

src/main/java/redis/clients/jedis/Connection.java

@@ -68,12 +68,16 @@ public void connect() throws UnknownHostException, IOException {
 	}
     }
 
-    public void disconnect() throws IOException {
+    public void disconnect() {
 	if (connected) {
-	    inputStream.close();
-	    outputStream.close();
-	    if (!socket.isClosed()) {
-		socket.close();
+	    try {
+		inputStream.close();
+		outputStream.close();
+		if (!socket.isClosed()) {
+		    socket.close();
+		}
+	    } catch (IOException ex) {
+		throw new JedisException(ex);
 	    }
 	    connected = false;
 	}

src/main/java/redis/clients/jedis/Jedis.java

@@ -638,4 +638,9 @@ public String info() {
 	client.info();
 	return client.getBulkReply();
     }
+
+    public void monitor(JedisMonitor jedisMonitor) {
+	client.monitor();
+	jedisMonitor.proceed(client);
+    }
 }

src/main/java/redis/clients/jedis/JedisMonitor.java

@@ -0,0 +1,15 @@
+package redis.clients.jedis;
+
+public abstract class JedisMonitor {
+    protected Client client;
+
+    public void proceed(Client client) {
+	this.client = client;
+	do {
+	    String command = client.getBulkReply();
+	    onCommand(command);
+	} while (client.isConnected());
+    }
+
+    public abstract void onCommand(String command);
+}

src/test/java/redis/clients/jedis/tests/commands/PersistenceControlCommandsTest.java

@@ -3,6 +3,7 @@
 import org.junit.Test;
 
 import redis.clients.jedis.JedisException;
+import redis.clients.jedis.JedisMonitor;
 
 public class PersistenceControlCommandsTest extends JedisCommandTestBase {
     @Test
@@ -40,8 +41,18 @@ public void lastsave() throws InterruptedException {
     }
 
     @Test
-    public void info() throws InterruptedException {
+    public void info() {
 	String info = jedis.info();
 	assertNotNull(info);
     }
+
+    @Test
+    public void monitor() {
+	jedis.monitor(new JedisMonitor() {
+	    public void onCommand(String command) {
+		assertTrue(command.contains("OK"));
+		client.disconnect();
+	    }
+	});
+    }
 }