diff --git a/hystrix-amqp/src/test/java/demo/HystrixApplicationTests.java b/hystrix-amqp/src/test/java/demo/HystrixApplicationTests.java index 7535654..1f37dc3 100644 --- a/hystrix-amqp/src/test/java/demo/HystrixApplicationTests.java +++ b/hystrix-amqp/src/test/java/demo/HystrixApplicationTests.java @@ -57,7 +57,7 @@ public class HystrixApplicationTests { byte[] buffer = new byte[1024]; in.read(buffer); String contents = new String(buffer); - assertTrue("Wrong content: \n" + contents, contents.contains("data")); + assertTrue("Wrong content: \n" + contents, contents.contains("data") || contents.contains("ping")); in.close(); } } diff --git a/hystrix/src/test/java/demo/HystrixApplicationTests.java b/hystrix/src/test/java/demo/HystrixApplicationTests.java index 7535654..1f37dc3 100644 --- a/hystrix/src/test/java/demo/HystrixApplicationTests.java +++ b/hystrix/src/test/java/demo/HystrixApplicationTests.java @@ -57,7 +57,7 @@ public class HystrixApplicationTests { byte[] buffer = new byte[1024]; in.read(buffer); String contents = new String(buffer); - assertTrue("Wrong content: \n" + contents, contents.contains("data")); + assertTrue("Wrong content: \n" + contents, contents.contains("data") || contents.contains("ping")); in.close(); } }