diff --git a/java/src/hop/Relay.java b/java/src/hop/Relay.java index 20388d5..3bbc8fa 100644 --- a/java/src/hop/Relay.java +++ b/java/src/hop/Relay.java @@ -108,9 +108,6 @@ public class Relay implements Runnable, Node, Flushable { System.err.println("Double bind attempted"); } else { _remoteName = m.getBytes(1).getDataString(); - synchronized (this) { - this.notifyAll(); - } if (_container.bind(_remoteName, this)) { String replySink = m.getBytes(4).getDataString(); if (replySink.length() > 0) { @@ -119,6 +116,9 @@ public class Relay implements Runnable, Node, Flushable { } else { System.err.println("Bind failed: " + _remoteName); } + synchronized (this) { + this.notifyAll(); + } } } else if (selector.equals("unsubscribe") && m.size() == 2) { if (!m.getBytes(1).getDataString().equals(_remoteName)) {