@InterfaceAudience.LimitedPrivate(value="Configuration") 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(ClusterStatus cs) |
public void connect(Configuration conf)
throws java.io.IOException
connect in interface ClusterStatusPublisher.Publisherjava.io.IOExceptionpublic void publish(ClusterStatus cs)
publish in interface ClusterStatusPublisher.Publisherpublic void close()
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in interface ClusterStatusPublisher.Publisher