Fix CI build

libamqpprox/amqpprox_closeerror.h

@@ -27,16 +27,22 @@ namespace amqpprox {
  * \brief Custom exception class
  *
  * This class will be used to throw custom exception, whenever we get the
- * connection Close method from server. Using this exception, we are going to
- * pass connection Close method to the exception handler. The exception handler
- * eventually can send the Close method to clients for better error handling.
+ * unexpected connection Close method from server during handshake. Using this
+ * exception, we are going to pass connection Close method to the exception
+ * handler. The exception handler eventually can send the Close method to
+ * clients for better error handling.
  */
 class CloseError : public std::runtime_error {
     methods::Close d_closeMethod;
 
   public:
+    // CREATORS
     CloseError(const std::string &msg, methods::Close &closeMethod);
 
+    // ACCESSORS
+    /**
+     * \return connection Close method
+     */
     methods::Close closeMethod() const;
 };
 

libamqpprox/amqpprox_connector.cpp

@@ -215,7 +215,7 @@ void Connector::receive(const Method &method, FlowType direction)
     } break;
     // Acting as a client
     case State::STARTOK_SENT: {
-        decodeMethod(&d_receivedTune, method, methodPayload);
+        decodeMethod(&d_receivedTune, method, methodPayload, direction);
         LOG_TRACE << "Server Tune: " << d_receivedTune;
 
         sendResponse(d_tuneOk, false);

libamqpprox/amqpprox_session.cpp

@@ -765,7 +765,8 @@ void Session::handleData(FlowType direction)
         sendSyntheticData();
 
         std::ostringstream oss;
-        oss << error.what() << ", Received method: " << receivedClose;
+        oss << error.what()
+            << ", Received method from server: " << receivedClose;
         logException(oss.str(), d_sessionState, direction);
 
         disconnect(true);
@@ -882,5 +883,6 @@ void Session::performDisconnectBoth()
                  << ", server=" << serverCloseEc;
     }
 }
+
 }
 }

tests/amqpprox_session.t.cpp

@@ -368,7 +368,7 @@ void SessionTest::testSetupProxyOutOfOrderOpen(int idx)
 
 void SessionTest::testSetupProxyReceiveClose(int idx)
 {
-    // Client                       Proxy  <--------Close------ Broker
+    // Client  <--------Close------  Proxy  <--------Close------  Broker
     d_clientState.pushItem(idx, Data(encode(close())));
 
     d_serverState.expect(idx, [this](const auto &items) {