) throws IgniteCheckedException {
assert timeout > 0 || skipOnTimeout;
ClusterNode node = ctx.discovery().node(nodeId);
if (node == null)
throw new IgniteCheckedException("Failed to send message to node (has node left grid?): " + nodeId);
<BUG>send(node, topic, (byte)-1, msg, plc, true, timeout, skipOnTimeout, ackC);
</BUG>
}
private void send(
Collection<? extends ClusterNode> nodes,

) throws IgniteCheckedException {
assert timeout > 0 || skipOnTimeout;
ClusterNode node = ctx.discovery().node(nodeId);
if (node == null)
throw new IgniteCheckedException("Failed to send message to node (has node left grid?): " + nodeId);
send(node, topic, (byte)-1, msg, plc, true, timeout, skipOnTimeout, ackC, false);
}
private void send(
Collection<? extends ClusterNode> nodes,
