statement changes

Steven
1 parent e8f6540b
Showing 1 changed file with 5 additions and 4 deletions
src/clientpaho.cpp
@@ -377,10 +377,10 @@ std::int32_t ClientPaho::publish( const MqttMessage&amp; message, int qos )
     }
     std::unique_lock<std::mutex> lck(m_mutex);
-    if( ConnectionStatus::ReconnectInProgress == m_connectionStatus || ConnectionStatus::ConnectInProgress == m_connectionStatus || m_processPendingPublishes )
+    if( ConnectionStatus::Connected != m_connectionStatus || m_processPendingPublishes )
     {
         m_pendingPublishesReadyCV.wait(lck, [this]() { return !m_processPendingPublishes; });
-        if( ConnectionStatus::ReconnectInProgress == m_connectionStatus || ConnectionStatus::ConnectInProgress == m_connectionStatus )
+        if( ConnectionStatus::Connected != m_connectionStatus )
         {
             LogDebug( "[ClientPaho::publish]", "Adding publish to pending queue." );
             m_pendingPublishes.push_front( Publish{ qos, message } );
@@ -789,6 +789,8 @@ void ClientPaho::onConnectOnInstance( const std::string&amp; cause )
 void ClientPaho::onConnectSuccessOnInstance()
 {
+    m_processPendingPublishes = true;
+
     LogDebug( "[ClientPaho::onConnectSuccessOnInstance]",
               std::string( m_clientId + " - onConnectSuccessOnInstance triggered." ) );
     {
@@ -1127,8 +1129,7 @@ void ClientPaho::onFirstConnect( void* context, char* cause )
     {
         auto *cl = reinterpret_cast<ClientPaho*>( context );
         std::string reason( nullptr == cause ? "Unknown cause" : cause );
-        //cl->pushIncomingEvent( [cl, reason]() { cl->onConnectSuccessOnInstance(); } );
-        cl->pushIncomingEvent( [cl, reason]() { cl->onConnectOnInstance( reason ); } );
+        cl->pushIncomingEvent( [cl, reason]() { cl->onConnectSuccessOnInstance(); } );
     }
 }