From 62d40667b01526acc0d1620efda66b686bc4394f Mon Sep 17 00:00:00 2001 From: reugn Date: Fri, 21 Jun 2024 19:09:08 +0300 Subject: [PATCH] fix(connectors): string formatting for message type --- aerospike/aerospike.go | 2 +- extension/net.go | 2 +- websocket/web_socket.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/aerospike/aerospike.go b/aerospike/aerospike.go index fba5d5f..c02d4ec 100644 --- a/aerospike/aerospike.go +++ b/aerospike/aerospike.go @@ -256,7 +256,7 @@ loop: log.Printf("Error parsing bin map: %s", err) } default: - log.Printf("Unsupported message type %v", message) + log.Printf("Unsupported message type: %T", message) } case <-flushTickerChan: as.flushBuffer() diff --git a/extension/net.go b/extension/net.go index a1b3e42..5b04c43 100644 --- a/extension/net.go +++ b/extension/net.go @@ -175,7 +175,7 @@ func (ns *NetSink) init() { writer.Flush() } default: - log.Printf("NetSink unsupported message type %v", m) + log.Printf("NetSink unsupported message type: %T", m) } } diff --git a/websocket/web_socket.go b/websocket/web_socket.go index 895f965..8bc37f7 100644 --- a/websocket/web_socket.go +++ b/websocket/web_socket.go @@ -132,7 +132,7 @@ func (wsock *Sink) init() { case []byte: err = wsock.connection.WriteMessage(ws.BinaryMessage, m) default: - log.Printf("Unsupported message type %v", m) + log.Printf("Unsupported message type: %T", m) } if err != nil {