in common/src/main/java/org/apache/cassandra/sidecar/common/JmxClient.java [190:208]
public void handleNotification(Notification notification, Object handback)
{
if (notification instanceof JMXConnectionNotification)
{
JMXConnectionNotification connectNotice = (JMXConnectionNotification) notification;
final String type = connectNotice.getType();
if (type.equals(JMXConnectionNotification.CLOSED) ||
type.equals(JMXConnectionNotification.FAILED) ||
type.equals(JMXConnectionNotification.NOTIFS_LOST) ||
type.equals(JMXConnectionNotification.OPENED))
{
boolean justConnected = type.equals(JMXConnectionNotification.OPENED);
synchronized (this)
{
this.connected = justConnected;
}
}
}
}