A.notNull(topic, "topic");
try {
if (msg instanceof Message)
ctx.io().send(node, topic, (Message)msg, SYSTEM_POOL);
else
<BUG>ctx.io().sendUserMessage(Collections.singletonList(node), msg, topic, false, 0);
</BUG>
}
catch (IgniteCheckedException e) {
throw unwrapException(e);

A.notNull(topic, "topic");
try {
if (msg instanceof Message)
ctx.io().send(node, topic, (Message)msg, SYSTEM_POOL);
else
ctx.io().sendUserMessage(Collections.singletonList(node), msg, topic, false, 0, false);
}
catch (IgniteCheckedException e) {
throw unwrapException(e);
