From ebfc543aef6920d3e2a99c79633a701d5ed3a9a6 Mon Sep 17 00:00:00 2001
From: Hua Jigang <gsteel@foxmail.com>
Date: Sat, 24 Feb 2018 12:17:02 +0800
Subject: [PATCH 1/2] change redis push way from right push to left push
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

改变将 binlog json 写入 redis 的方向,由 rpush 改为 lpush,以方便 consumer 使用 RPOPLPUSH
---
 canal-client/src/canal/client/redis.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/canal-client/src/canal/client/redis.java b/canal-client/src/canal/client/redis.java
index 5e4cf0f..d6c2488 100644
--- a/canal-client/src/canal/client/redis.java
+++ b/canal-client/src/canal/client/redis.java
@@ -34,7 +34,7 @@ public void push_redis(Map<String, String> conf, String[] argv) throws java.io.I
     	
     	Jedis jedis = new Jedis(host, port);
         for(int i=0;i<argv.length;i++){
-        	jedis.rpush(queuename, argv[i]);
+        	jedis.lpush(queuename, argv[i]);
         }
         
 	}

From 819381a53b40c07ad8de84286f9c1cb75709ae1a Mon Sep 17 00:00:00 2001
From: Hua Jigang <gsteel@foxmail.com>
Date: Sat, 24 Feb 2018 15:30:23 +0800
Subject: [PATCH 2/2] update annotation for push list direction

---
 canal-client/src/canal/client/redis.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/canal-client/src/canal/client/redis.java b/canal-client/src/canal/client/redis.java
index d6c2488..9463858 100644
--- a/canal-client/src/canal/client/redis.java
+++ b/canal-client/src/canal/client/redis.java
@@ -1,6 +1,6 @@
 /**
  * @author liukelin
- * rpush / lpop 
+ * lpush / rpop 
  */
 package canal.client;