Update sentinel ready pattern for redis 3.2 and add an overloaded sta…

src/main/java/redis/embedded/AbstractRedisInstance.java

@@ -28,15 +28,20 @@ public boolean isActive() {
         return active;
     }
 
-	@Override
+    @Override
     public synchronized void start() throws EmbeddedRedisException {
+        start(redisReadyPattern());
+    }
+
+    @Override
+    public synchronized void start(String redisReadyPattern) throws EmbeddedRedisException {
         if (active) {
             throw new EmbeddedRedisException("This redis server instance is already running...");
         }
         try {
             redisProcess = createRedisProcessBuilder().start();
             logErrors();
-            awaitRedisServerReady();
+            awaitRedisServerReady(redisReadyPattern);
             active = true;
         } catch (IOException e) {
             throw new EmbeddedRedisException("Failed to start Redis instance", e);
@@ -51,7 +56,7 @@ private void logErrors() {
         executor.submit(printReaderTask);
     }
 
-    private void awaitRedisServerReady() throws IOException {
+    private void awaitRedisServerReady(String redisReadyPattern) throws IOException {
         BufferedReader reader = new BufferedReader(new InputStreamReader(redisProcess.getInputStream()));
         try {
             String outputLine;
@@ -61,7 +66,7 @@ private void awaitRedisServerReady() throws IOException {
                     //Something goes wrong. Stream is ended before server was activated.
                     throw new RuntimeException("Can't start redis server. Check logs for details.");
                 }
-            } while (!outputLine.matches(redisReadyPattern()));
+            } while (!outputLine.matches(redisReadyPattern));
         } finally {
             IOUtils.closeQuietly(reader);
         }

src/main/java/redis/embedded/Redis.java

@@ -9,6 +9,8 @@ public interface Redis {
 
     void start() throws EmbeddedRedisException;
 
+    void start(String redisReadyPattern) throws EmbeddedRedisException;
+
     void stop() throws EmbeddedRedisException;
 
     List<Integer> ports();

src/main/java/redis/embedded/RedisCluster.java

@@ -41,6 +41,16 @@ public void start() throws EmbeddedRedisException {
         }
     }
 
+    @Override
+    public void start(String redisReadyPattern) throws EmbeddedRedisException {
+        for(Redis redis : sentinels) {
+            redis.start(redisReadyPattern);
+        }
+        for(Redis redis : servers) {
+            redis.start(redisReadyPattern);
+        }
+    }
+
     @Override
     public void stop() throws EmbeddedRedisException {
         for(Redis redis : sentinels) {

src/main/java/redis/embedded/RedisSentinel.java

@@ -4,7 +4,7 @@
 import java.util.List;
 
 public class RedisSentinel extends AbstractRedisInstance {
-    private static final String REDIS_READY_PATTERN = ".*Sentinel runid is.*";
+    private static final String REDIS_READY_PATTERN = ".*Sentinel (runid|ID) is.*";
 
     public RedisSentinel(List<String> args, int port) {
         super(port);