ClusterNode locNode = F.find(nodes, null, F.localNode(locNodeId));
Collection<? extends ClusterNode> rmtNodes = F.view(nodes, F.remoteNodes(locNodeId));
if (!rmtNodes.isEmpty())
send(rmtNodes, TOPIC_COMM_USER, ioMsg, PUBLIC_POOL);
if (locNode != null)
<BUG>send(locNode, TOPIC_COMM_USER, ioMsg, PUBLIC_POOL);
</BUG>
}
}
@SuppressWarnings("unchecked")

ClusterNode locNode = F.find(nodes, null, F.localNode(locNodeId));
Collection<? extends ClusterNode> rmtNodes = F.view(nodes, F.remoteNodes(locNodeId));
if (!rmtNodes.isEmpty())
send(rmtNodes, TOPIC_COMM_USER, ioMsg, PUBLIC_POOL);
if (locNode != null)
send(locNode, TOPIC_COMM_USER, ioMsg, PUBLIC_POOL, async);
}
}
@SuppressWarnings("unchecked")
