diff options
Diffstat (limited to 'juick-server-xmpp')
-rw-r--r-- | juick-server-xmpp/src/main/java/com/juick/server/XMPPServer.java | 20 |
1 files changed, 8 insertions, 12 deletions
diff --git a/juick-server-xmpp/src/main/java/com/juick/server/XMPPServer.java b/juick-server-xmpp/src/main/java/com/juick/server/XMPPServer.java index c4f6bb19..a324282c 100644 --- a/juick-server-xmpp/src/main/java/com/juick/server/XMPPServer.java +++ b/juick-server-xmpp/src/main/java/com/juick/server/XMPPServer.java @@ -19,7 +19,6 @@ package com.juick.server; import com.juick.server.xmpp.s2s.*; import com.juick.service.UserService; -import com.juick.server.xmpp.extensions.JuickMessage; import com.juick.xmpp.extensions.StreamError; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,7 +28,6 @@ import org.springframework.stereotype.Component; import org.xmlpull.v1.XmlPullParserException; import rocks.xmpp.addr.Jid; import rocks.xmpp.core.stanza.model.Stanza; -import rocks.xmpp.util.XmppUtils; import javax.annotation.PostConstruct; import javax.annotation.PreDestroy; @@ -37,20 +35,19 @@ import javax.inject.Inject; import javax.net.ssl.*; import javax.xml.bind.JAXBException; import javax.xml.bind.Unmarshaller; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamWriter; -import java.io.*; -import java.net.*; +import java.io.FileInputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.StringReader; +import java.net.ServerSocket; +import java.net.Socket; +import java.net.SocketException; import java.security.KeyStore; import java.security.KeyStoreException; import java.security.SecureRandom; import java.time.Duration; import java.time.Instant; -import java.util.Arrays; -import java.util.List; -import java.util.Map; -import java.util.NoSuchElementException; -import java.util.Optional; +import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.ExecutorService; @@ -248,7 +245,6 @@ public class XMPPServer implements ConnectionListener, AutoCloseable { connectionOut.setInputStream(socket.getInputStream()); connectionOut.setOutputStream(socket.getOutputStream()); addConnectionOut(connectionOut, Optional.of(socket)); - connectionOut.addChildParser(new JuickMessage()); connectionOut.connect(); } catch (IOException e) { userService.getActiveJIDs().stream().filter(j -> Jid.of(j).getDomain().equals(to)) |