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