diff --git a/tap/extensions/amqp/helpers.go b/tap/extensions/amqp/helpers.go index d6e841d11..4dcd99118 100644 --- a/tap/extensions/amqp/helpers.go +++ b/tap/extensions/amqp/helpers.go @@ -559,7 +559,7 @@ func emitConnectionStart(event ConnectionStart, connectionInfo *api.ConnectionIn Type: "connection_start", Data: &AMQPWrapper{ Method: connectionMethodMap[10], - Url: fmt.Sprintf("%s.%s", string(event.VersionMajor), string(event.VersionMinor)), + Url: fmt.Sprintf("%d.%d", event.VersionMajor, event.VersionMinor), Details: event, }, }, diff --git a/tap/extensions/amqp/main.go b/tap/extensions/amqp/main.go index 956d6f5fe..24e8e9b29 100644 --- a/tap/extensions/amqp/main.go +++ b/tap/extensions/amqp/main.go @@ -6,6 +6,7 @@ import ( "fmt" "io" "log" + "strconv" "github.com/up9inc/mizu/tap/api" ) @@ -223,7 +224,11 @@ func (d dissecting) Analyze(item *api.OutputChannelItem, entryId string, resolve summary = reqDetails["Queue"].(string) break case connectionMethodMap[10]: - summary = fmt.Sprintf("%g.%g", reqDetails["VersionMajor"].(float64), reqDetails["VersionMinor"].(float64)) + summary = fmt.Sprintf( + "%s.%s", + strconv.Itoa(int(reqDetails["VersionMajor"].(float64))), + strconv.Itoa(int(reqDetails["VersionMinor"].(float64))), + ) break case connectionMethodMap[50]: summary = reqDetails["ReplyText"].(string)