+ public static <T> void assertNoneMatching(ActorRef actor, Class<T> clazz) {
+ assertNoneMatching(actor, clazz, 5000);
+ }
+
+ public static <T> void assertNoneMatching(ActorRef actor, Class<T> clazz, long timeout) {
+ int count = (int) (timeout / 50);
+ for(int i = 0; i < count; i++) {
+ try {
+ T message = getFirstMatching(actor, clazz);
+ if(message != null) {
+ Assert.fail("Unexpected message received" + message.toString());
+ return;
+ }
+ } catch (Exception e) {}
+
+ Uninterruptibles.sleepUninterruptibly(50, TimeUnit.MILLISECONDS);
+ }
+
+ return;
+ }
+
+