MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reconnect even when Smack thinks it doesn't need to.

This commit is contained in:
Moxie Marlinspike 2014-10-01 14:07:12 -07:00
parent b944b86bf8
commit 30017371df
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/whispersystems/textsecuregcm/push/GCMSender.java
View File

@ -200,6 +200,11 @@ public class GCMSender implements Managed, PacketListener {
throws SmackException.NotConnectedException throws SmackException.NotConnectedException
{ {
logger.warn("Got upstream message from GCM Server!"); logger.warn("Got upstream message from GCM Server!");
for (String key : message.keySet()) {
logger.warn(key + " : " + message.get(key));
}
Map<String, Object> ack = new HashMap<>(); Map<String, Object> ack = new HashMap<>();
message.put("message_type", "ack"); message.put("message_type", "ack");
message.put("to", message.get("from")); message.put("to", message.get("from"));
@ -362,6 +367,7 @@ public class GCMSender implements Managed, PacketListener {
@Override @Override
public void reconnectionFailed(Exception e) { public void reconnectionFailed(Exception e) {
logger.warn("GCM XMPP Reconnection failed!", e); logger.warn("GCM XMPP Reconnection failed!", e);
reconnect();
} }
@Override @Override
@ -377,6 +383,7 @@ public class GCMSender implements Managed, PacketListener {
@Override @Override
public void connectionClosed() { public void connectionClosed() {
logger.warn("GCM XMPP Connection closed."); logger.warn("GCM XMPP Connection closed.");
reconnect();
} }
} }