diff --git a/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java b/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java
index 2ea1d5556..e82608e4a 100644
--- a/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java
+++ b/src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java
@@ -15,6 +15,8 @@
  */
 package org.springframework.data.redis.connection.jredis;
 
+import java.lang.reflect.Method;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.LinkedHashSet;
@@ -28,7 +30,9 @@ import org.jredis.JRedis;
 import org.jredis.Query.Support;
 import org.jredis.RedisException;
 import org.jredis.Sort;
+import org.jredis.protocol.Command;
 import org.jredis.ri.alphazero.JRedisService;
+import org.jredis.ri.alphazero.JRedisSupport;
 import org.springframework.dao.DataAccessException;
 import org.springframework.data.redis.RedisSystemException;
 import org.springframework.data.redis.connection.DataType;
@@ -37,6 +41,7 @@ import org.springframework.data.redis.connection.RedisConnection;
 import org.springframework.data.redis.connection.SortParameters;
 import org.springframework.data.redis.connection.Subscription;
 import org.springframework.util.Assert;
+import org.springframework.util.ReflectionUtils;
 
 /**
  * {@code RedisConnection} implementation on top of <a href="http://github.com/alphazero/jredis">JRedis</a> library.
@@ -45,10 +50,18 @@ import org.springframework.util.Assert;
  */
 public class JredisConnection implements RedisConnection {
 
+	private static final Method SERVICE_REQUEST;
+
 	private final JRedis jredis;
 	private final boolean isPool;
 	private boolean isClosed = false;
 
+	static {
+		SERVICE_REQUEST = ReflectionUtils.findMethod(JRedisSupport.class, "serviceRequest", Command.class,
+				byte[][].class);
+		ReflectionUtils.makeAccessible(SERVICE_REQUEST);
+	}
+
 	/**
 	 * Constructs a new <code>JredisConnection</code> instance.
 	 *
@@ -73,7 +86,18 @@ public class JredisConnection implements RedisConnection {
 		return new RedisSystemException("Unknown JRedis exception", ex);
 	}
 
-	
+	public Object execute(String command, byte[]... args) {
+		Assert.hasText(command, "a valid command needs to be specified");
+		List<byte[]> mArgs = new ArrayList<byte[]>();
+		if (args != null) {
+			Collections.addAll(mArgs, args);
+		}
+
+		return ReflectionUtils.invokeMethod(SERVICE_REQUEST, jredis, Command.valueOf(command.trim().toUpperCase()),
+				mArgs.toArray(new byte[mArgs.size()][]));
+
+	}
+
 	public void close() throws RedisSystemException {
 		isClosed = true;
 
@@ -88,37 +112,37 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public JRedis getNativeConnection() {
 		return jredis;
 	}
 
-	
+
 	public boolean isClosed() {
 		return isClosed;
 	}
 
-	
+
 	public boolean isQueueing() {
 		return false;
 	}
 
-	
+
 	public boolean isPipelined() {
 		return false;
 	}
 
-	
+
 	public void openPipeline() {
 		throw new UnsupportedOperationException("Pipelining not supported by JRedis");
 	}
 
-	
+
 	public List<Object> closePipeline() {
 		return Collections.emptyList();
 	}
 
-	
+
 	public List<byte[]> sort(byte[] key, SortParameters params) {
 		Sort sort = jredis.sort(JredisUtils.decode(key));
 		JredisUtils.applySortingParams(sort, params, null);
@@ -129,7 +153,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long sort(byte[] key, SortParameters params, byte[] storeKey) {
 		Sort sort = jredis.sort(JredisUtils.decode(key));
 		JredisUtils.applySortingParams(sort, params, null);
@@ -140,7 +164,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long dbSize() {
 		try {
 			return jredis.dbsize();
@@ -149,7 +173,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void flushDb() {
 		try {
 			jredis.flushdb();
@@ -158,7 +182,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void flushAll() {
 		try {
 			jredis.flushall();
@@ -167,7 +191,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] echo(byte[] message) {
 		try {
 			return jredis.echo(message);
@@ -176,7 +200,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public String ping() {
 		try {
 			jredis.ping();
@@ -186,7 +210,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void bgSave() {
 		try {
 			jredis.bgsave();
@@ -195,7 +219,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void bgWriteAof() {
 		try {
 			jredis.bgrewriteaof();
@@ -204,7 +228,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void save() {
 		try {
 			jredis.save();
@@ -213,12 +237,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public List<String> getConfig(String pattern) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Properties info() {
 		try {
 			return JredisUtils.info(jredis.info());
@@ -227,7 +251,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long lastSave() {
 		try {
 			return jredis.lastsave();
@@ -236,22 +260,22 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void setConfig(String param, String value) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public void resetConfigStats() {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public void shutdown() {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long del(byte[]... keys) {
 		try {
 			return jredis.del(JredisUtils.decodeMultiple(keys));
@@ -260,7 +284,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void discard() {
 		try {
 			jredis.discard();
@@ -269,12 +293,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public List<Object> exec() {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Boolean exists(byte[] key) {
 		try {
 			return jredis.exists(JredisUtils.decode(key));
@@ -283,7 +307,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean expire(byte[] key, long seconds) {
 		try {
 			return jredis.expire(JredisUtils.decode(key), (int) seconds);
@@ -292,7 +316,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean expireAt(byte[] key, long unixTime) {
 		try {
 			return jredis.expireat(JredisUtils.decode(key), unixTime);
@@ -301,7 +325,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<byte[]> keys(byte[] pattern) {
 		try {
 			return JredisUtils.convertToSet(jredis.keys(JredisUtils.decode(pattern)));
@@ -310,18 +334,18 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void multi() {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Boolean persist(byte[] key) {
 		throw new UnsupportedOperationException();
 	}
 
 
-	
+
 	public Boolean move(byte[] key, int dbIndex) {
 		try {
 			return jredis.move(JredisUtils.decode(key), dbIndex);
@@ -330,7 +354,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] randomKey() {
 		try {
 			return JredisUtils.encode(jredis.randomkey());
@@ -339,7 +363,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void rename(byte[] oldName, byte[] newName) {
 		try {
 			jredis.rename(JredisUtils.decode(oldName), JredisUtils.decode(newName));
@@ -348,7 +372,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean renameNX(byte[] oldName, byte[] newName) {
 		try {
 			return jredis.renamenx(JredisUtils.decode(oldName), JredisUtils.decode(newName));
@@ -357,12 +381,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void select(int dbIndex) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long ttl(byte[] key) {
 		try {
 			return jredis.ttl(JredisUtils.decode(key));
@@ -371,7 +395,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public DataType type(byte[] key) {
 		try {
 			return JredisUtils.convertDataType(jredis.type(JredisUtils.decode(key)));
@@ -380,12 +404,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void unwatch() {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public void watch(byte[]... keys) {
 		throw new UnsupportedOperationException();
 	}
@@ -394,7 +418,7 @@ public class JredisConnection implements RedisConnection {
 	// String operations
 	//
 
-	
+
 	public byte[] get(byte[] key) {
 		try {
 			return jredis.get(JredisUtils.decode(key));
@@ -403,7 +427,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void set(byte[] key, byte[] value) {
 		try {
 			jredis.set(JredisUtils.decode(key), value);
@@ -412,7 +436,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] getSet(byte[] key, byte[] value) {
 		try {
 			return jredis.getset(JredisUtils.decode(key), value);
@@ -421,7 +445,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long append(byte[] key, byte[] value) {
 		try {
 			return jredis.append(JredisUtils.decode(key), value);
@@ -430,7 +454,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public List<byte[]> mGet(byte[]... keys) {
 		try {
 			return jredis.mget(JredisUtils.decodeMultiple(keys));
@@ -439,7 +463,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void mSet(Map<byte[], byte[]> tuple) {
 		try {
 			jredis.mset(JredisUtils.decodeMap(tuple));
@@ -448,7 +472,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void mSetNX(Map<byte[], byte[]> tuple) {
 		try {
 			jredis.msetnx(JredisUtils.decodeMap(tuple));
@@ -457,12 +481,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void setEx(byte[] key, long seconds, byte[] value) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Boolean setNX(byte[] key, byte[] value) {
 		try {
 			return jredis.setnx(JredisUtils.decode(key), value);
@@ -471,7 +495,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] getRange(byte[] key, long start, long end) {
 		try {
 			return jredis.substr(JredisUtils.decode(key), start, end);
@@ -480,7 +504,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long decr(byte[] key) {
 		try {
 			return jredis.decr(JredisUtils.decode(key));
@@ -489,7 +513,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long decrBy(byte[] key, long value) {
 		try {
 			return jredis.decrby(JredisUtils.decode(key), (int) value);
@@ -498,7 +522,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long incr(byte[] key) {
 		try {
 			return jredis.incr(JredisUtils.decode(key));
@@ -507,7 +531,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long incrBy(byte[] key, long value) {
 		try {
 			return jredis.incrby(JredisUtils.decode(key), (int) value);
@@ -516,22 +540,22 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean getBit(byte[] key, long offset) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public void setBit(byte[] key, long offset, boolean value) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public void setRange(byte[] key, byte[] value, long start) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long strLen(byte[] key) {
 		throw new UnsupportedOperationException();
 	}
@@ -540,17 +564,17 @@ public class JredisConnection implements RedisConnection {
 	// List commands
 	//
 
-	
+
 	public List<byte[]> bLPop(int timeout, byte[]... keys) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public List<byte[]> bRPop(int timeout, byte[]... keys) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public byte[] lIndex(byte[] key, long index) {
 		try {
 			return jredis.lindex(JredisUtils.decode(key), index);
@@ -559,7 +583,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long lLen(byte[] key) {
 		try {
 			return jredis.llen(JredisUtils.decode(key));
@@ -568,7 +592,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] lPop(byte[] key) {
 		try {
 			return jredis.lpop(JredisUtils.decode(key));
@@ -577,7 +601,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long lPush(byte[] key, byte[] value) {
 		try {
 			jredis.lpush(JredisUtils.decode(key), value);
@@ -587,7 +611,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public List<byte[]> lRange(byte[] key, long start, long end) {
 		try {
 			List<byte[]> lrange = jredis.lrange(JredisUtils.decode(key), start, end);
@@ -598,7 +622,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long lRem(byte[] key, long count, byte[] value) {
 		try {
 			return jredis.lrem(JredisUtils.decode(key), value, (int) count);
@@ -607,7 +631,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void lSet(byte[] key, long index, byte[] value) {
 		try {
 			jredis.lset(JredisUtils.decode(key), index, value);
@@ -616,7 +640,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public void lTrim(byte[] key, long start, long end) {
 		try {
 			jredis.ltrim(JredisUtils.decode(key), start, end);
@@ -625,7 +649,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] rPop(byte[] key) {
 		try {
 			return jredis.rpop(JredisUtils.decode(key));
@@ -634,7 +658,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] rPopLPush(byte[] srcKey, byte[] dstKey) {
 		try {
 			return jredis.rpoplpush(JredisUtils.decode(srcKey), JredisUtils.decode(dstKey));
@@ -643,7 +667,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long rPush(byte[] key, byte[] value) {
 		try {
 			jredis.rpush(JredisUtils.decode(key), value);
@@ -653,22 +677,22 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long lInsert(byte[] key, Position where, byte[] pivot, byte[] value) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public byte[] bRPopLPush(int timeout, byte[] srcKey, byte[] dstKey) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long lPushX(byte[] key, byte[] value) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long rPushX(byte[] key, byte[] value) {
 		throw new UnsupportedOperationException();
 	}
@@ -678,7 +702,7 @@ public class JredisConnection implements RedisConnection {
 	// Set commands
 	//
 
-	
+
 	public Boolean sAdd(byte[] key, byte[] value) {
 		try {
 			return jredis.sadd(JredisUtils.decode(key), value);
@@ -687,7 +711,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long sCard(byte[] key) {
 		try {
 			return jredis.scard(JredisUtils.decode(key));
@@ -696,7 +720,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<byte[]> sDiff(byte[]... keys) {
 		String destKey = JredisUtils.decode(keys[0]);
 		String[] sets = JredisUtils.decodeMultiple(Arrays.copyOfRange(keys, 1, keys.length));
@@ -709,7 +733,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long sDiffStore(byte[] destKey, byte[]... keys) {
 		String destSet = JredisUtils.decode(destKey);
 		String[] sets = JredisUtils.decodeMultiple(keys);
@@ -722,7 +746,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<byte[]> sInter(byte[]... keys) {
 		String set1 = JredisUtils.decode(keys[0]);
 		String[] sets = JredisUtils.decodeMultiple(Arrays.copyOfRange(keys, 1, keys.length));
@@ -735,7 +759,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long sInterStore(byte[] destKey, byte[]... keys) {
 		String destSet = JredisUtils.decode(destKey);
 		String[] sets = JredisUtils.decodeMultiple(keys);
@@ -748,7 +772,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean sIsMember(byte[] key, byte[] value) {
 		try {
 			return jredis.sismember(JredisUtils.decode(key), value);
@@ -757,7 +781,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<byte[]> sMembers(byte[] key) {
 		try {
 			return new LinkedHashSet<byte[]>(jredis.smembers(JredisUtils.decode(key)));
@@ -766,7 +790,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean sMove(byte[] srcKey, byte[] destKey, byte[] value) {
 		try {
 			return jredis.smove(JredisUtils.decode(srcKey), JredisUtils.decode(destKey), value);
@@ -775,7 +799,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] sPop(byte[] key) {
 		try {
 			return jredis.spop(JredisUtils.decode(key));
@@ -784,7 +808,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] sRandMember(byte[] key) {
 		try {
 			return jredis.srandmember(JredisUtils.decode(key));
@@ -793,7 +817,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean sRem(byte[] key, byte[] value) {
 		try {
 			return jredis.srem(JredisUtils.decode(key), value);
@@ -802,7 +826,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<byte[]> sUnion(byte[]... keys) {
 		String set1 = JredisUtils.decode(keys[0]);
 		String[] sets = JredisUtils.decodeMultiple(Arrays.copyOfRange(keys, 1, keys.length));
@@ -814,7 +838,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long sUnionStore(byte[] destKey, byte[]... keys) {
 		String destSet = JredisUtils.decode(destKey);
 		String[] sets = JredisUtils.decodeMultiple(keys);
@@ -832,7 +856,7 @@ public class JredisConnection implements RedisConnection {
 	// ZSet commands
 	//
 
-	
+
 	public Boolean zAdd(byte[] key, double score, byte[] value) {
 		try {
 			return jredis.zadd(JredisUtils.decode(key), score, value);
@@ -841,7 +865,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long zCard(byte[] key) {
 		try {
 			return jredis.zcard(JredisUtils.decode(key));
@@ -850,7 +874,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long zCount(byte[] key, double min, double max) {
 		try {
 			return jredis.zcount(JredisUtils.decode(key), min, max);
@@ -859,7 +883,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Double zIncrBy(byte[] key, double increment, byte[] value) {
 		try {
 			return jredis.zincrby(JredisUtils.decode(key), increment, value);
@@ -868,17 +892,17 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long zInterStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long zInterStore(byte[] destKey, byte[]... sets) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<byte[]> zRange(byte[] key, long start, long end) {
 		try {
 			return new LinkedHashSet<byte[]>(jredis.zrange(JredisUtils.decode(key), start, end));
@@ -887,12 +911,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<Tuple> zRangeWithScores(byte[] key, long start, long end) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<byte[]> zRangeByScore(byte[] key, double min, double max) {
 		try {
 			return new LinkedHashSet<byte[]>(jredis.zrangebyscore(JredisUtils.decode(key), min, max));
@@ -901,42 +925,42 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<Tuple> zRangeByScoreWithScores(byte[] key, double min, double max) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<byte[]> zRangeByScore(byte[] key, double min, double max, long offset, long count) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<Tuple> zRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<byte[]> zRevRangeByScore(byte[] key, double min, double max, long offset, long count) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<byte[]> zRevRangeByScore(byte[] key, double min, double max) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<Tuple> zRevRangeByScoreWithScores(byte[] key, double min, double max, long offset, long count) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<Tuple> zRevRangeByScoreWithScores(byte[] key, double min, double max) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long zRank(byte[] key, byte[] value) {
 		try {
 			return jredis.zrank(JredisUtils.decode(key), value);
@@ -945,7 +969,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean zRem(byte[] key, byte[] value) {
 		try {
 			return jredis.zrem(JredisUtils.decode(key), value);
@@ -954,7 +978,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long zRemRange(byte[] key, long start, long end) {
 		try {
 			return jredis.zremrangebyrank(JredisUtils.decode(key), start, end);
@@ -963,7 +987,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long zRemRangeByScore(byte[] key, double min, double max) {
 		try {
 			return jredis.zremrangebyscore(JredisUtils.decode(key), min, max);
@@ -972,7 +996,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<byte[]> zRevRange(byte[] key, long start, long end) {
 		try {
 			return new LinkedHashSet<byte[]>(jredis.zrevrange(JredisUtils.decode(key), start, end));
@@ -981,12 +1005,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Set<Tuple> zRevRangeWithScores(byte[] key, long start, long end) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long zRevRank(byte[] key, byte[] value) {
 		try {
 			return jredis.zrevrank(JredisUtils.decode(key), value);
@@ -995,7 +1019,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Double zScore(byte[] key, byte[] value) {
 		try {
 			return jredis.zscore(JredisUtils.decode(key), value);
@@ -1009,17 +1033,17 @@ public class JredisConnection implements RedisConnection {
 	// Hash commands
 	//
 
-	
+
 	public Long zUnionStore(byte[] destKey, Aggregate aggregate, int[] weights, byte[]... sets) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long zUnionStore(byte[] destKey, byte[]... sets) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Boolean hDel(byte[] key, byte[] field) {
 		try {
 			return jredis.hdel(JredisUtils.decode(key), JredisUtils.decode(field));
@@ -1028,7 +1052,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean hExists(byte[] key, byte[] field) {
 		try {
 			return jredis.hexists(JredisUtils.decode(key), JredisUtils.decode(field));
@@ -1037,7 +1061,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public byte[] hGet(byte[] key, byte[] field) {
 		try {
 			return jredis.hget(JredisUtils.decode(key), JredisUtils.decode(field));
@@ -1046,7 +1070,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Map<byte[], byte[]> hGetAll(byte[] key) {
 		try {
 			return JredisUtils.encodeMap(jredis.hgetall(JredisUtils.decode(key)));
@@ -1055,12 +1079,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long hIncrBy(byte[] key, byte[] field, long delta) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Set<byte[]> hKeys(byte[] key) {
 		try {
 			return new LinkedHashSet<byte[]>(JredisUtils.convertToSet(jredis.hkeys(JredisUtils.decode(key))));
@@ -1069,7 +1093,7 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Long hLen(byte[] key) {
 		try {
 			return jredis.hlen(JredisUtils.decode(key));
@@ -1078,17 +1102,17 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public List<byte[]> hMGet(byte[] key, byte[]... fields) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public void hMSet(byte[] key, Map<byte[], byte[]> values) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Boolean hSet(byte[] key, byte[] field, byte[] value) {
 		try {
 			return jredis.hset(JredisUtils.decode(key), JredisUtils.decode(field), value);
@@ -1097,12 +1121,12 @@ public class JredisConnection implements RedisConnection {
 		}
 	}
 
-	
+
 	public Boolean hSetNX(byte[] key, byte[] field, byte[] value) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public List<byte[]> hVals(byte[] key) {
 		try {
 			return jredis.hvals(JredisUtils.decode(key));
@@ -1115,27 +1139,27 @@ public class JredisConnection implements RedisConnection {
 	// PubSub commands
 	//
 
-	
+
 	public Subscription getSubscription() {
 		return null;
 	}
 
-	
+
 	public boolean isSubscribed() {
 		return false;
 	}
 
-	
+
 	public void pSubscribe(MessageListener listener, byte[]... patterns) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public Long publish(byte[] channel, byte[] message) {
 		throw new UnsupportedOperationException();
 	}
 
-	
+
 	public void subscribe(MessageListener listener, byte[]... channels) {
 		throw new UnsupportedOperationException();
 	}
diff --git a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java
index 6dc0354a9..94badf377 100644
--- a/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java
+++ b/src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java
@@ -336,5 +336,8 @@ public abstract class AbstractConnectionIntegrationTests {
 	@Test
 	public void testExecuteNative() throws Exception {
 		connection.execute("ZADD", getClass() + "#testExecuteNative", "0.9090", "item");
+		//connection.execute("PiNg");
+		connection.execute("iNFo");
+		connection.execute("SET ", getClass() + "testSetNative", UUID.randomUUID().toString());
 	}
 }
\ No newline at end of file