add lettuce into the test batch

DATAREDIS-113
2013-02-07 20:19:39 +02:00
parent 694481cee5
commit 0851fa3c20
3 changed files with 55 additions and 4 deletions
--- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java
+++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java
@@ -145,6 +145,11 @@ public class LettuceConnection implements RedisConnection {
 		} catch (RuntimeException ex) {
 			throw convertLettuceAccessException(ex);
 		}
+
+		if (subscription != null) {
+			subscription.doClose();
+			subscription = null;
+		}
 	}

 	public boolean isClosed() {
@@ -179,7 +184,7 @@ public class LettuceConnection implements RedisConnection {
 			List<Object> results = new ArrayList<Object>(ppline.size());

 			Exception problem = null;
-			
+
 			if (done) {
 				for (Command<?, ?, ?> cmd : ppline) {
 					if (cmd.getOutput().hasError()) {