diff --git a/src/main/java/redis/clients/jedis/MultiKeyPipelineBase.java b/src/main/java/redis/clients/jedis/MultiKeyPipelineBase.java index c0bc5bc12b..4039423f03 100644 --- a/src/main/java/redis/clients/jedis/MultiKeyPipelineBase.java +++ b/src/main/java/redis/clients/jedis/MultiKeyPipelineBase.java @@ -709,10 +709,14 @@ public Response migrate(final String host, final int port, final int des return getResponse(BuilderFactory.STRING); } - @Override - public Response sendCommand(ProtocolCommand cmd, String... args){ + public Response sendCommand(final ProtocolCommand cmd, final String... args) { client.sendCommand(cmd, args); return getResponse(BuilderFactory.OBJECT); } - + + public Response sendCommand(final ProtocolCommand cmd, final byte[]... args) { + client.sendCommand(cmd, args); + return getResponse(BuilderFactory.OBJECT); + } + } diff --git a/src/main/java/redis/clients/jedis/PipelineBase.java b/src/main/java/redis/clients/jedis/PipelineBase.java index 05502f6763..968aad5d60 100644 --- a/src/main/java/redis/clients/jedis/PipelineBase.java +++ b/src/main/java/redis/clients/jedis/PipelineBase.java @@ -1975,15 +1975,13 @@ public Response> xclaim(byte[] key, byte[] group, byte[] consumerna return getResponse(BuilderFactory.BYTE_ARRAY_LIST); } - public Response sendCommand(ProtocolCommand cmd, String... args){ - String key = args.length > 0 ? args[0] : cmd.toString(); - getClient(key).sendCommand(cmd, args); + public Response sendCommand(final String sampleKey, final ProtocolCommand cmd, final String... args) { + getClient(sampleKey).sendCommand(cmd, args); return getResponse(BuilderFactory.OBJECT); } - public Response sendCommand(ProtocolCommand cmd, byte[]... args){ - byte[] key = args.length > 0 ? args[0] : cmd.getRaw(); - getClient(key).sendCommand(cmd, args); + public Response sendCommand(final byte[] sampleKey, final ProtocolCommand cmd, final byte[]... args) { + getClient(sampleKey).sendCommand(cmd, args); return getResponse(BuilderFactory.OBJECT); } }