From c050c5ec2e079d91409e1abfe214e3eb1799bd22 Mon Sep 17 00:00:00 2001 From: Joc Date: Wed, 27 Feb 2019 13:08:46 +0100 Subject: [PATCH] Throw qualified EmbeddedRedisException when startup fails --- src/main/java/redis/embedded/AbstractRedisInstance.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/redis/embedded/AbstractRedisInstance.java b/src/main/java/redis/embedded/AbstractRedisInstance.java index abeae789..029b9690 100644 --- a/src/main/java/redis/embedded/AbstractRedisInstance.java +++ b/src/main/java/redis/embedded/AbstractRedisInstance.java @@ -51,7 +51,7 @@ private void logErrors() { executor.submit(printReaderTask); } - private void awaitRedisServerReady() throws IOException { + private void awaitRedisServerReady() throws IOException, EmbeddedRedisException { BufferedReader reader = new BufferedReader(new InputStreamReader(redisProcess.getInputStream())); try { String outputLine; @@ -59,7 +59,7 @@ private void awaitRedisServerReady() throws IOException { outputLine = reader.readLine(); if (outputLine == null) { //Something goes wrong. Stream is ended before server was activated. - throw new RuntimeException("Can't start redis server. Check logs for details."); + throw new EmbeddedRedisException("Can't start redis server. Check logs for details."); } } while (!outputLine.matches(redisReadyPattern())); } finally {