From 39d568d396a2c54ee315878b503334efa5989ff7 Mon Sep 17 00:00:00 2001 From: damencho Date: Mon, 2 Dec 2024 11:55:24 -0600 Subject: [PATCH] feat: Enables stream resumption. --- .../org/jitsi/xmpp/mucclient/MucClient.java | 28 +++++++++++++++---- 1 file changed, 22 insertions(+), 6 deletions(-) diff --git a/jicoco/src/main/java/org/jitsi/xmpp/mucclient/MucClient.java b/jicoco/src/main/java/org/jitsi/xmpp/mucclient/MucClient.java index c337e14..02ab234 100644 --- a/jicoco/src/main/java/org/jitsi/xmpp/mucclient/MucClient.java +++ b/jicoco/src/main/java/org/jitsi/xmpp/mucclient/MucClient.java @@ -55,8 +55,8 @@ public class MucClient static { - XMPPTCPConnection.setUseStreamManagementDefault(false); - XMPPTCPConnection.setUseStreamManagementResumptionDefault(false); + XMPPTCPConnection.setUseStreamManagementDefault(true); + XMPPTCPConnection.setUseStreamManagementResumptionDefault(true); PingManager.setDefaultPingInterval(DEFAULT_PING_INTERVAL_SECONDS); } @@ -318,13 +318,25 @@ private void initializeConnectAndJoin() public void connected(XMPPConnection xmppConnection) { mucClientManager.connected(MucClient.this); - logger.info("Connected."); + + if (xmppConnection instanceof XMPPTCPConnection) + { + XMPPTCPConnection connection = (XMPPTCPConnection) xmppConnection; + + logger.info("Connected. isSmEnabled:" + connection.isSmEnabled() + + " isSmAvailable:" + connection.isSmAvailable() + + " isSmResumptionPossible:" + connection.isSmResumptionPossible()); + } + else + { + logger.info("Connected."); + } } @Override - public void authenticated(XMPPConnection xmppConnection, boolean b) + public void authenticated(XMPPConnection xmppConnection, boolean resumed) { - logger.info("Authenticated, b=" + b); + logger.info("Authenticated, resumed=" + resumed); } @Override @@ -664,7 +676,11 @@ private Callable getConnectAndLoginCallable() try { - joinMucs(); + if (!(xmppConnection instanceof XMPPTCPConnection + && ((XMPPTCPConnection)xmppConnection).streamWasResumed())) + { + joinMucs(); + } } catch(Exception e) {