aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGravatar Vitaly Takmazov2016-11-11 13:21:21 +0300
committerGravatar Vitaly Takmazov2016-11-11 13:21:21 +0300
commit99efc3e6edbb7877091124336d6e115da0af67b1 (patch)
tree6d46a2e2374084656fbb8d20fdc53c66f9d65cd0
parent48c1dd8e27ccca932f482766e0747dd3a61b1e98 (diff)
fix connection router
-rw-r--r--juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionRouter.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionRouter.java b/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionRouter.java
index b10d2540..8514436d 100644
--- a/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionRouter.java
+++ b/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionRouter.java
@@ -60,7 +60,7 @@ public class ConnectionRouter extends Connection implements Runnable {
while (!execution.isComplete()) {
try {
AsynchronousSocketChannel socket = AsynchronousSocketChannel.open();
- socket.connect(new InetSocketAddress(componentPort));
+ socket.connect(new InetSocketAddress("localhost", componentPort)).get();
parser.setInput(new InputStreamReader(Channels.newInputStream(socket)));
parser.setFeature(XmlPullParser.FEATURE_PROCESS_NAMESPACES, true);
writer = new OutputStreamWriter(Channels.newOutputStream(socket));
@@ -260,4 +260,4 @@ public class ConnectionRouter extends Connection implements Runnable {
}
}
}
-} \ No newline at end of file
+}