diff --git a/src/test/java/teetime/stage/opad/filter/AnomalyDetectionFilterTest.java b/src/test/java/teetime/stage/opad/filter/AnomalyDetectionFilterTest.java
index 857592e2e2ae32e70ac44d9e335878de81f819c0..70331a85ffee7c01e55b359812d33630a1c1e4a6 100644
--- a/src/test/java/teetime/stage/opad/filter/AnomalyDetectionFilterTest.java
+++ b/src/test/java/teetime/stage/opad/filter/AnomalyDetectionFilterTest.java
@@ -15,6 +15,8 @@
  */
 package teetime.stage.opad.filter;
 
+import static org.hamcrest.Matchers.empty;
+import static org.hamcrest.Matchers.is;
 import static org.hamcrest.collection.IsIterableContainingInOrder.contains;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertThat;
@@ -66,7 +68,7 @@ public class AnomalyDetectionFilterTest {
 		assertThat(resultsNormalPort, contains(input1, input2));
 
 		test(adf).and().send(input1, input2).to(adf.getInputPort()).and().receive(resultsAnnormalPort).from(adf.getOutputPortAnnormal()).start();
-		assertEquals(0, resultsAnnormalPort.size());
+		assertThat(resultsAnnormalPort, is(empty()));
 
 	}