private void add(final InetAddress node) {
if (channels.contains(node)) {
return;
}
LOGGER.debug("Adding DCP Channel against {}", node);
<BUG>DcpChannel channel = new DcpChannel(node, env);
</BUG>
channels.add(channel);
channel.connect().subscribe();
}

private void add(final InetAddress node) {
if (channels.contains(node)) {
return;
}
LOGGER.debug("Adding DCP Channel against {}", node);
DcpChannel channel = new DcpChannel(node, env, this);
channels.add(channel);
channel.connect().subscribe();
}
