Correcting that binary data cannot be received under cluster status (#…

…185)

Correcting that binary data cannot be received under cluster status

go.mod

@@ -3,28 +3,29 @@ module github.com/DrmagicE/gmqtt
 go 1.14
 
 require (
-	github.com/golang/mock v1.4.4
-	github.com/golang/protobuf v1.4.2
+	github.com/golang/glog v1.0.0 // indirect
+	github.com/golang/mock v1.6.0
+	github.com/golang/protobuf v1.5.2
 	github.com/gomodule/redigo v1.8.2
-	github.com/google/uuid v1.1.2
+	github.com/google/uuid v1.3.0
 	github.com/gorilla/websocket v1.4.2
 	github.com/grpc-ecosystem/go-grpc-middleware v1.0.0
 	github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0
 	github.com/grpc-ecosystem/grpc-gateway v1.16.0
+	github.com/hashicorp/go-immutable-radix v1.0.0 // indirect
 	github.com/hashicorp/go-sockaddr v1.0.0
 	github.com/hashicorp/logutils v1.0.0
 	github.com/hashicorp/serf v0.9.5
 	github.com/iancoleman/strcase v0.1.2
 	github.com/pkg/errors v0.8.1
 	github.com/prometheus/client_golang v1.4.0
 	github.com/spf13/cobra v1.0.0
-	github.com/stretchr/testify v1.6.1
+	github.com/stretchr/testify v1.7.0
 	go.uber.org/zap v1.13.0
-	golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9
-	golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd
-	golang.org/x/tools v0.0.0-20191112195655-aa38f8e97acc // indirect
-	google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013
-	google.golang.org/grpc v1.34.0
-	google.golang.org/protobuf v1.25.0
-	gopkg.in/yaml.v2 v2.2.5
+	golang.org/x/crypto v0.0.0-20210921155107-089bfa567519
+	golang.org/x/sys v0.0.0-20220728004956-3c1f35247d10
+	google.golang.org/genproto v0.0.0-20221201204527-e3fa12d562f3
+	google.golang.org/grpc v1.50.1
+	google.golang.org/protobuf v1.28.1
+	gopkg.in/yaml.v2 v2.4.0
 )

plugin/federation/federation.go

@@ -581,7 +581,7 @@ func (f *Federation) Name() string {
 func messageToEvent(msg *gmqtt.Message) *Message {
 	eventMsg := &Message{
 		TopicName:       msg.Topic,
-		Payload:         string(msg.Payload),
+		Payload:         msg.Payload,
 		Qos:             uint32(msg.QoS),
 		Retained:        msg.Retained,
 		ContentType:     msg.ContentType,
@@ -607,7 +607,7 @@ func eventToMessage(event *Message) *gmqtt.Message {
 		QoS:             byte(event.Qos),
 		Retained:        event.Retained,
 		Topic:           event.TopicName,
-		Payload:         []byte(event.Payload),
+		Payload:         event.Payload,
 		ContentType:     event.ContentType,
 		CorrelationData: []byte(event.CorrelationData),
 		MessageExpiry:   event.MessageExpiry,