improve logging

cloudamqp · Dec 19, 2024 · d44c0d6 · d44c0d6
1 parent e2ed10b
commit d44c0d6
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/lavinmq/amqp/connection_factory.cr b/src/lavinmq/amqp/connection_factory.cr
@@ -47,7 +47,10 @@ module LavinMQ
         elsif proto != AMQP::PROTOCOL_START_0_9_1 && proto != AMQP::PROTOCOL_START_0_9
           socket.write AMQP::PROTOCOL_START_0_9_1.to_slice
           socket.flush
-          log.warn { "Unexpected protocol '#{String.new(proto.to_slice)}', closing socket" }
+          log.warn {
+            bad_protocol = String.new(proto.to_slice).gsub(/\n/, "\\n")
+            "Unexpected protocol '#{bad_protocol}', closing socket"
+            }
           false
         else
           true