guard();
try {
Collection<ClusterNode> snapshot = prj.nodes();
if (snapshot.isEmpty())
throw U.emptyTopologyException();
<BUG>ctx.io().sendUserMessage(snapshot, msg, topic, false, 0);
</BUG>
}
catch (IgniteCheckedException e) {
throw U.convertException(e);

guard();
try {
Collection<ClusterNode> snapshot = prj.nodes();
if (snapshot.isEmpty())
throw U.emptyTopologyException();
ctx.io().sendUserMessage(snapshot, msg, topic, false, 0, isAsync());
}
catch (IgniteCheckedException e) {
throw U.convertException(e);
