From 377c266dc1e7678b6a91d8dc9c41ab20115b947b Mon Sep 17 00:00:00 2001 From: Yaourt Date: Thu, 4 Nov 2010 10:31:20 +0100 Subject: [PATCH] Add a sendCommand(String byte[]...) method. --- src/main/java/redis/clients/jedis/Connection.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/main/java/redis/clients/jedis/Connection.java b/src/main/java/redis/clients/jedis/Connection.java index 0efea87..4802570 100644 --- a/src/main/java/redis/clients/jedis/Connection.java +++ b/src/main/java/redis/clients/jedis/Connection.java @@ -62,6 +62,19 @@ public class Connection { return this; } + protected Connection sendCommand(final String name, final byte[]... args) { + try { + connect(); + } catch (UnknownHostException e) { + throw new JedisException("Could not connect to redis-server", e); + } catch (IOException e) { + throw new JedisException("Could not connect to redis-server", e); + } + protocol.sendCommand(outputStream, name, args); + pipelinedCommands++; + return this; + } + public Connection(final String host, final int port) { super(); this.host = host;