public static class ClusterStatusPublisher.MulticastPublisher extends java.lang.Object implements ClusterStatusPublisher.Publisher
Constructor and Description |
---|
MulticastPublisher() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
connect(Configuration conf) |
void |
publish(ClusterMetrics cs) |
public void connect(Configuration conf) throws java.io.IOException
connect
in interface ClusterStatusPublisher.Publisher
java.io.IOException
public void publish(ClusterMetrics cs)
publish
in interface ClusterStatusPublisher.Publisher
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface ClusterStatusPublisher.Publisher