From cd3b50268e03e4b66d6a3ced49c9ee092ea3475f Mon Sep 17 00:00:00 2001
From: Jonathan Leibiusky <ionathan@gmail.com>
Date: Wed, 11 May 2011 22:29:42 -0300
Subject: [PATCH] add publish command to Pipeline

---
 src/main/java/redis/clients/jedis/Pipeline.java       | 10 ++++++++++
 .../redis/clients/jedis/tests/PipeliningTest.java     | 11 +++++++++++
 2 files changed, 21 insertions(+)

diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java
index 72b267c..d904fc5 100644
--- a/src/main/java/redis/clients/jedis/Pipeline.java
+++ b/src/main/java/redis/clients/jedis/Pipeline.java
@@ -1155,4 +1155,14 @@ public class Pipeline extends Queable {
     public void multi() {
         client.multi();
     }
+
+    public Response<Long> publish(String channel, String message) {
+        client.publish(channel, message);
+        return getResponse(BuilderFactory.LONG);
+    }
+
+    public Response<Long> publish(byte[] channel, byte[] message) {
+        client.publish(channel, message);
+        return getResponse(BuilderFactory.LONG);
+    }
 }
diff --git a/src/test/java/redis/clients/jedis/tests/PipeliningTest.java b/src/test/java/redis/clients/jedis/tests/PipeliningTest.java
index 2e02a7e..cb82fd1 100644
--- a/src/test/java/redis/clients/jedis/tests/PipeliningTest.java
+++ b/src/test/java/redis/clients/jedis/tests/PipeliningTest.java
@@ -103,4 +103,15 @@ public class PipeliningTest extends Assert {
         string.get();
         p.sync();
     }
+
+    @Test
+    public void pipelineWithPubSub() {
+        Pipeline pipelined = jedis.pipelined();
+        Response<Long> p1 = pipelined.publish("foo", "bar");
+        Response<Long> p2 = pipelined.publish("foo".getBytes(), "bar"
+                .getBytes());
+        pipelined.sync();
+        assertEquals(0, p1.get().longValue());
+        assertEquals(0, p2.get().longValue());
+    }
 }
\ No newline at end of file