Index: core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java =================================================================== --- core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java (revision 1502594) +++ core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java (working copy) @@ -90,7 +90,7 @@ this.peer = peer; this.conf = conf; this.peerAddress = peerAddress; - this.localQueue = getSenderQueue(); + this.localQueue = getReceiverQueue(); this.localQueueForNextIteration = getSynchronizedReceiverQueue(); this.maxCachedConnections = conf.getInt(MAX_CACHED_CONNECTIONS_KEY, 100); }