From ce876e2b5673c069984e4648236334e4d8a88674 Mon Sep 17 00:00:00 2001 From: Yaourt Date: Thu, 4 Nov 2010 09:21:18 +0100 Subject: [PATCH] Add a binary sendCommand(...) --- .../java/redis/clients/jedis/Protocol.java | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java index e9e6211..cd23107 100644 --- a/src/main/java/redis/clients/jedis/Protocol.java +++ b/src/main/java/redis/clients/jedis/Protocol.java @@ -43,6 +43,26 @@ public final class Protocol { } } + public void sendCommand(RedisOutputStream os, String name, byte[]... args) { + try { + os.write(ASTERISK_BYTE); + os.writeIntCrLf(args.length + 1); + os.write(DOLLAR_BYTE); + os.writeIntCrLf(name.length()); + os.writeAsciiCrLf(name); + + for (final byte[] arg : args) { + os.write(DOLLAR_BYTE); + os.writeIntCrLf(arg.length); + os.write(arg); + os.writeCrLf(); + } + os.flush(); + } catch (IOException e) { + throw new JedisException(e); + } + } + private void processError(RedisInputStream is) { String message = is.readLine(); throw new JedisException(message);