in src/main/java/org/apache/cassandra/distributed/api/NodeToolResult.java [122:135]
public Asserts notificationContains(String msg)
{
AssertUtils.assertNotNull("notifications not defined", notifications);
AssertUtils.assertFalse("notifications not defined", notifications.isEmpty());
for (Notification n : notifications)
{
if (n.getMessage().contains(msg))
{
return this;
}
}
fail("Unable to locate message " + msg + " in notifications: " + NodeToolResult.toString(notifications));
return this; // unreachable
}