diff --git a/src/main/java/redis/clients/jedis/Transaction.java b/src/main/java/redis/clients/jedis/Transaction.java index fa1446c..4650a0d 100644 --- a/src/main/java/redis/clients/jedis/Transaction.java +++ b/src/main/java/redis/clients/jedis/Transaction.java @@ -566,4 +566,15 @@ public class Transaction extends BinaryTransaction { client.lastsave(); return getResponse(BuilderFactory.LONG); } + + public Response publish(String channel, String message) { + client.publish(channel, message); + return getResponse(BuilderFactory.LONG); + } + + public Response publish(byte[] channel, byte[] message) { + client.publish(channel, message); + return getResponse(BuilderFactory.LONG); + } + } \ No newline at end of file diff --git a/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java b/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java index 83798c2..af31b64 100644 --- a/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java +++ b/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java @@ -219,4 +219,15 @@ public class TransactionCommandsTest extends JedisCommandTestBase { string.get(); t.exec(); } + + @Test + public void lala() { + Transaction multi = jedis.multi(); + Response publish = multi.publish("foo", "bar"); + Response bpublish = multi.publish("foo".getBytes(), "bar" + .getBytes()); + multi.exec(); + assertEquals(0, publish.get().longValue()); + assertEquals(0, bpublish.get().longValue()); + } } \ No newline at end of file