Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
…cubator-ignite into ignite-24

Conflicts:
	modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java
	modules/core/src/test/java/org/apache/ignite/session/GridSessionLoadSelfTest.java
  • Loading branch information
Yakov Zhdanov committed Jan 27, 2015
1 parent a4d5dc6 commit 8bef53e
Showing 1 changed file with 27 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -963,6 +963,33 @@ public void sendOrderedMessage(
send(node, topic, (byte)-1, msg, plc, true, timeout, skipOnTimeout);
}

/**
* @param nodeId Destination node.
* @param topic Topic to send the message to.
* @param msg Message to send.
* @param plc Type of processing.
* @param timeout Timeout to keep a message on receiving queue.
* @param skipOnTimeout Whether message can be skipped on timeout.
* @throws IgniteCheckedException Thrown in case of any errors.
*/
public void sendOrderedMessage(
UUID nodeId,
Object topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout
) 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);
}

/**
* @param nodes Destination nodes.
* @param topic Topic to send the message to.
Expand Down

0 comments on commit 8bef53e

Please sign in to comment.