vanitasvitae/Smack
1
0
Fork 0
mirror of https://github.com/vanitasvitae/Smack.git synced 2024-11-30 16:02:07 +01:00
Code Issues Releases Wiki Activity

call onlineSetup method on initial connection

Browse source
This commit is contained in:
Paul Schaub 2020-02-16 22:43:41 +01:00
parent 0d90e6535e
commit 7a33471325
Signed by: vanitasvitae
GPG key ID: 62BEE9264BF17311
1 changed files with 21 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
smack-messenger/src/main/java/org/jivesoftware/smackx/messenger/Messenger.java
View file

@ -4,6 +4,7 @@ import java.util.Map;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import org.jivesoftware.smack.AbstractConnectionListener;
import org.jivesoftware.smack.ReconnectionManager; import org.jivesoftware.smack.ReconnectionManager;
import org.jivesoftware.smack.SmackException; import org.jivesoftware.smack.SmackException;
import org.jivesoftware.smack.XMPPConnection; import org.jivesoftware.smack.XMPPConnection;
@ -51,6 +52,21 @@ public class Messenger implements ClientStateListener {
offlineAccountSetup(xmppAccount); offlineAccountSetup(xmppAccount);
connection.addConnectionListener(new AbstractConnectionListener() {
@Override
public void authenticated(XMPPConnection connection, boolean resumed) {
if (resumed) {
return;
}
try {
onlineAccountSetup(xmppAccount);
} catch (InterruptedException | XMPPException | SmackException e) {
e.printStackTrace();
}
}
});
return xmppAccount; return xmppAccount;
} }
@ -61,11 +77,12 @@ public class Messenger implements ClientStateListener {
private void onlineAccountSetup(XmppAccount account) private void onlineAccountSetup(XmppAccount account)
throws InterruptedException, XMPPException, SmackException { throws InterruptedException, XMPPException, SmackException {
if (CarbonManager.getInstanceFor(account.getConnection()).isSupportedByServer()) {
CarbonManager.getInstanceFor(account.getConnection()).enableCarbons(); // Enable Carbons
CarbonManager carbonManager = CarbonManager.getInstanceFor(account.getConnection());
if (carbonManager.isSupportedByServer()) {
carbonManager.enableCarbons();
} }
} }
@Override @Override