#IGNITE-1034 - Corrected messages after code review.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/e1b88003 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/e1b88003 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/e1b88003 Branch: refs/heads/ignite-648 Commit: e1b880030aae7ef9cfa6a812d17a97cf8055dfd5 Parents: 7a8b572 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Fri Jun 19 10:57:04 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Fri Jun 19 10:57:04 2015 -0700 ---------------------------------------------------------------------- .../ignite/spi/communication/tcp/TcpCommunicationSpi.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/e1b88003/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java index a540b7c..3997768 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java @@ -1158,6 +1158,9 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter * <p/> * When set to a positive number, communication SPI will monitor clients outbound queue sizes and will drop * those clients whose queue exceeded this limit. + * <p/> + * Usually this value should be set to the same value as {@link #getMessageQueueLimit()} which controls + * message back-pressure for server nodes. The default value for this parameter is {@link #DFLT_MSG_QUEUE_LIMIT}. * * @param slowClientQueueLimit Slow cilent queue limit. */ @@ -1913,8 +1916,8 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter ClusterNode node = getSpiContext().node(id); if (node != null && node.isClient()) { - String msg = "Client node outbound queue size exceed configured slow client queue limit, " + - "will fail the node (consider changing \'slowClientQueueLimit\') [clientNode=" + node + + String msg = "Client node outbound queue size exceeded slowClientQueueLimit, " + + "the client will be dropped (consider changing \'slowClientQueueLimit\') [clientNode=" + node + ", slowClientQueueLimit=" + slowClientQueueLimit + ']'; LT.warn(log, null, msg);
