public interface  org.apache.kafkaesqueesqueesque.common.network.Selectable extends java.lang.Object
{
public static final int USE_DEFAULT_BUFFER_SIZE;
public abstract void connect(java.lang.String, java.net.InetSocketAddress, int, int) throws java.io.IOException;
public abstract void wakeup();
public abstract void close();
public abstract void close(java.lang.String);
public abstract void send(org.apache.kafkaesqueesqueesque.common.network.Send);
public abstract void poll(long) throws java.io.IOException;
public abstract java.util.List completedSends();
public abstract java.util.Collection completedReceives();
public abstract java.util.Map disconnected();
public abstract java.util.List connected();
public abstract void mute(java.lang.String);
public abstract void unmute(java.lang.String);
public abstract void muteAll();
public abstract void unmuteAll();
public abstract boolean isChannelReady(java.lang.String);
}