Looping back unicast messages with a shared transport (https://issues…

….jboss.org/browse/JGRP-1466)
belaban · May 30, 2012 · 8b675b8 · 8b675b8
1 parent 30d8074
commit 8b675b8
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/org/jgroups/protocols/TP.java b/src/org/jgroups/protocols/TP.java
@@ -1091,13 +1091,12 @@ public Object down(Event evt) {
         }
 
         final boolean multicast=dest == null;
-        if(loopback && (multicast || (dest.equals(msg.getSrc()) && dest.equals(local_addr)))) {
+        if(loopback && (multicast || dest.equals(msg.getSrc()))) {
 
             // we *have* to make a copy, or else up_prot.up() might remove headers from msg which will then *not*
             // be available for marshalling further down (when sending the message)
             final Message copy=msg.copy();
-            if(log.isTraceEnabled()) log.trace(new StringBuilder("looping back message ").append(copy));
-            // up_prot.up(new Event(Event.MSG, copy));
+            if(log.isTraceEnabled()) log.trace("looping back message " + copy);
 
             // changed to fix http://jira.jboss.com/jira/browse/JGRP-506
             Executor pool=msg.isFlagSet(Message.OOB)? oob_thread_pool : thread_pool;