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