ETM-Schurig/powersync-core
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

enable auto reconnect

Browse Source
This commit is contained in:
Michael Zanetti 2018-08-30 20:13:19 +02:00
parent 096a285212
commit 2f2787fb98
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
libnymea-core/cloud/awsconnector.cpp
View File

@ -96,12 +96,13 @@ void AWSConnector::doConnect()
m_client->setVersion(QMQTT::V3_1_1); m_client->setVersion(QMQTT::V3_1_1);
m_client->setKeepAlive(30*60); m_client->setKeepAlive(30*60);
m_client->setCleanSession(true); m_client->setCleanSession(true);
m_client->setAutoReconnect(true);
m_client->connectToHost(); m_client->connectToHost();
connect(m_client, &QMQTT::Client::connected, this, &AWSConnector::onConnected); connect(m_client, &QMQTT::Client::connected, this, &AWSConnector::onConnected);
connect(m_client, &QMQTT::Client::disconnected, this, &AWSConnector::onDisconnected); connect(m_client, &QMQTT::Client::disconnected, this, &AWSConnector::onDisconnected);
connect(m_client, &QMQTT::Client::error, this, [](const QMQTT::ClientError error){ connect(m_client, &QMQTT::Client::error, this, [](const QMQTT::ClientError error){
qDebug() << "error" << error; qCWarning(dcAWS()) << "An error happened in the MQTT transport" << error;
}); });
connect(m_client, &QMQTT::Client::subscribed, this, &AWSConnector::onSubscribed); connect(m_client, &QMQTT::Client::subscribed, this, &AWSConnector::onSubscribed);

3
libnymea-core/cloud/cloudtransport.cpp
View File

@ -85,7 +85,6 @@ void CloudTransport::connectToCloud(const QString &token)
void CloudTransport::remoteConnectionStateChanged(RemoteProxyConnection::State state) void CloudTransport::remoteConnectionStateChanged(RemoteProxyConnection::State state)
{ {
qCDebug(dcCloud) << "Remote connection state changed" << state;
RemoteProxyConnection *proxyConnection = qobject_cast<RemoteProxyConnection*>(sender()); RemoteProxyConnection *proxyConnection = qobject_cast<RemoteProxyConnection*>(sender());
ConnectionContext context = m_connections.value(proxyConnection); ConnectionContext context = m_connections.value(proxyConnection);
@ -99,7 +98,7 @@ void CloudTransport::remoteConnectionStateChanged(RemoteProxyConnection::State s
emit clientDisconnected(context.clientId); emit clientDisconnected(context.clientId);
break; break;
default: default:
qCDebug(dcCloud()) << state; qCDebug(dcCloud()) << "Remote connection state changed" << state;
break; break;
} }
} }