// Finally, write the Publish request through the Channel.
if (logger.isDebugEnabled())
logger.debug("Writing a Publish request to host: " + HedwigClientImpl.getHostFromChannel(channel)
+ " for pubSubData: " + pubSubData);
ChannelFuture future = channel.write(pubsubRequestBuilder.build());
future.addListener(new WriteCallback(pubSubData, client));
}
// Synchronized method to store the host2Channel mapping (if it doesn't
// exist yet). Retrieve the hostname info from the Channel created via the
// RemoteAddress tied to it.