- support.notifyEntityOwnershipListeners(entity1, false, true);
-
- verify(mockListener1, timeout(5000)).ownershipChanged(entity1, false, true);
- verify(mockListener2, timeout(5000)).ownershipChanged(entity1, false, true);
- verify(mockListener3, timeout(5000)).ownershipChanged(entity1, false, true);
- assertEquals("# of listener actors", 3, actorContext.children().size());
-
- // Notify entity2 changed and verify only mockListener1 and mockListener3 are notified.
-
- support.notifyEntityOwnershipListeners(entity2, false, true);
-
- verify(mockListener1, timeout(5000)).ownershipChanged(entity2, false, true);
- verify(mockListener3, timeout(5000)).ownershipChanged(entity2, false, true);
- Uninterruptibles.sleepUninterruptibly(300, TimeUnit.MILLISECONDS);
- verify(mockListener2, never()).ownershipChanged(eq(entity2), anyBoolean(), anyBoolean());
- assertEquals("# of listener actors", 3, actorContext.children().size());
-
- // Notify entity3 changed and verify only mockListener3 is notified.
-
- support.notifyEntityOwnershipListeners(entity3, false, true);
-
- verify(mockListener3, timeout(5000)).ownershipChanged(entity3, false, true);
- Uninterruptibles.sleepUninterruptibly(300, TimeUnit.MILLISECONDS);
- verify(mockListener1, never()).ownershipChanged(eq(entity3), anyBoolean(), anyBoolean());
- verify(mockListener2, never()).ownershipChanged(eq(entity3), anyBoolean(), anyBoolean());
-
- // Notify entity4 changed and verify no listeners are notified.
-
- support.notifyEntityOwnershipListeners(entity4, false, true);