Clarify name of method for dropping messages
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/00613438 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/00613438 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/00613438 Branch: refs/heads/master Commit: 006134383ed448084e358f993e34f12ba5b45dcf Parents: b60ab23 Author: Michael G. Noll <[email protected]> Authored: Mon Feb 16 10:03:07 2015 +0100 Committer: Michael G. Noll <[email protected]> Committed: Mon Feb 16 10:03:07 2015 +0100 ---------------------------------------------------------------------- storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/00613438/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java index 71aa794..189fa95 100644 --- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java +++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java @@ -431,14 +431,14 @@ public class Client extends ConnectionWithStatus implements IStatefulObject { */ private void handleMessagesWhenConnectionIsUnavailable(Iterator<TaskMessage> msgs) { LOG.error("connection to {} is unavailable", dstAddressPrefixedName); - dropPendingMessages(msgs); + dropMessages(msgs); } - private void dropPendingMessages(Iterator<TaskMessage> msgs) { + private void dropMessages(Iterator<TaskMessage> msgs) { // We consume the iterator by traversing and thus "emptying" it. int msgCount = iteratorSize(msgs); messagesLost.getAndAdd(msgCount); - LOG.error("dropping {} pending message(s) destined for {}", msgCount, dstAddressPrefixedName); + LOG.error("dropping {} message(s) destined for {}", msgCount, dstAddressPrefixedName); } private int iteratorSize(Iterator<TaskMessage> msgs) {
