From d0e6e89ffb5aec12580c626a29ed9dd59969810e Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 6 Jan 2011 09:14:49 -0500 Subject: [PATCH] Only reply if non-empty sink name provided --- java/hop/Relay.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/java/hop/Relay.java b/java/hop/Relay.java index ea42bb7..e3b8e8d 100644 --- a/java/hop/Relay.java +++ b/java/hop/Relay.java @@ -7,9 +7,6 @@ package hop; import java.io.IOException; import java.io.OutputStream; import java.net.Socket; -import java.util.ArrayList; -import java.util.List; -import java.util.UUID; /** */ @@ -86,7 +83,7 @@ public class Relay implements Runnable, Node { if (m == null) { break; } - System.err.println("Received: " + m); + //System.err.println("Received: " + m); String selector = m.getBytes(0).getDataString(); if (selector.equals("post") && m.size() == 4) { _container.send(m.getBytes(1).getDataString(), m.get(2)); @@ -99,7 +96,10 @@ public class Relay implements Runnable, Node { this.notifyAll(); } if (_container.bind(_remoteName, this)) { - _container.post(m.getBytes(4).getDataString(), m.get(5), SexpMessage.subscribe_ok(_remoteName), null); + String replySink = m.getBytes(4).getDataString(); + if (replySink.length() > 0) { + _container.post(replySink, m.get(5), SexpMessage.subscribe_ok(_remoteName), null); + } } else { System.err.println("Bind failed: " + _remoteName); }