@@ -102,31 +102,31 @@ namespace iot::mqtt {
102102
103103 template <typename WSSubProtocolRole>
104104 void SubProtocol<WSSubProtocolRole>::onConnected() {
105- LOG (INFO) << getSocketConnection ()->getConnectionName () << " WSMQTT : connected:" ;
105+ LOG (INFO) << getSocketConnection ()->getConnectionName () << " WsMqtt : connected:" ;
106106 iot::mqtt::MqttContext::onConnected ();
107107 }
108108
109109 template <typename WSSubProtocolRole>
110110 void SubProtocol<WSSubProtocolRole>::onMessageStart(int opCode) {
111111 if (opCode == web::websocket::SubProtocolContext::OpCode::TEXT) {
112- LOG (ERROR) << getSocketConnection ()->getConnectionName () << " WSMQTT : Wrong Opcode: " << opCode;
112+ LOG (ERROR) << getSocketConnection ()->getConnectionName () << " WsMqtt : Wrong Opcode: " << opCode << " (TEXT) " ;
113113 this ->end (true );
114114 } else {
115- LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WSMQTT : Message START: " << opCode;
115+ LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WsMqtt : Message START: " << opCode << " (BIN) " ;
116116 }
117117 }
118118
119119 template <typename WSSubProtocolRole>
120120 void SubProtocol<WSSubProtocolRole>::onMessageData(const char * chunk, std::size_t chunkLen) {
121121 data.append (std::string (chunk, chunkLen));
122122
123- LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WebSocket : Frame Data:\n "
123+ LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WsMqtt : Frame Data:\n "
124124 << std::string (32 , ' ' ).append (utils::hexDump (std::vector<char >(chunk, chunk + chunkLen), 32 ));
125125 }
126126
127127 template <typename WSSubProtocolRole>
128128 void SubProtocol<WSSubProtocolRole>::onMessageEnd() {
129- LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WSMQTT : Message END" ;
129+ LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WsMqtt : Message END" ;
130130
131131 buffer.insert (buffer.end (), data.begin (), data.end ());
132132 size += data.size ();
@@ -144,19 +144,19 @@ namespace iot::mqtt {
144144
145145 template <typename WSSubProtocolRole>
146146 void SubProtocol<WSSubProtocolRole>::onMessageError(uint16_t errnum) {
147- LOG (ERROR) << getSocketConnection ()->getConnectionName () << " WSMQTT : Message error: " << errnum;
147+ LOG (ERROR) << getSocketConnection ()->getConnectionName () << " WsMqtt : Message error: " << errnum;
148148 }
149149
150150 template <typename WSSubProtocolRole>
151151 void SubProtocol<WSSubProtocolRole>::onDisconnected() {
152152 iot::mqtt::MqttContext::onDisconnected ();
153- LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WSMQTT : disconnected" ;
153+ LOG (DEBUG) << getSocketConnection ()->getConnectionName () << " WsMqtt : disconnected" ;
154154 }
155155
156156 template <typename WSSubProtocolRole>
157157 bool SubProtocol<WSSubProtocolRole>::onSignal(int sig) {
158158 bool ret = iot::mqtt::MqttContext::onSignal (sig);
159- LOG (INFO) << getSocketConnection ()->getConnectionName () << " WSMQTT : exit due to '" << strsignal (sig) << " ' (SIG"
159+ LOG (INFO) << getSocketConnection ()->getConnectionName () << " WsMqtt : exit due to '" << strsignal (sig) << " ' (SIG"
160160 << utils::system::sigabbrev_np (sig) << " = " << sig << " )" ;
161161
162162 this ->sendClose ();
0 commit comments