Skip to content
Browse files

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

  • Loading branch information...
1 parent 88ddc53 commit 6e94176aac5a2f42e0fff3db9eb67da7210d5216 @belaban committed May 30, 2012
Showing with 2 additions and 3 deletions.
  1. +2 −3 src/org/jgroups/protocols/TP.java
View
5 src/org/jgroups/protocols/TP.java
@@ -1117,13 +1117,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;

0 comments on commit 6e94176

Please sign in to comment.
Something went wrong with that request. Please try again.