Removed more unsafe operations.

vburenin · Jun 16, 2017 · a3e95bc · a3e95bc
1 parent 08c1cbb
commit a3e95bc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/server/sqsproto/receive_message/receive_message.go b/server/sqsproto/receive_message/receive_message.go
@@ -10,7 +10,6 @@ import (
 	"strings"
 
 	"github.com/vburenin/firempq/apis"
-	"github.com/vburenin/firempq/enc"
 	"github.com/vburenin/firempq/log"
 	"github.com/vburenin/firempq/mpqproto/resp"
 	"github.com/vburenin/firempq/pqueue"
@@ -120,7 +119,7 @@ func MakeMessageAttr(name string, sqsAttr *sqsmsg.UserAttribute) *MessageAttribu
 		return &MessageAttribute{
 			Name:        name,
 			Type:        sqsAttr.Type,
-			BinaryValue: enc.UnsafeBytesToString(encodedBin),
+			BinaryValue: string(encodedBin),
 		}
 	} else {
 		return &MessageAttribute{

diff --git a/server/sqsproto/send_message/send_message.go b/server/sqsproto/send_message/send_message.go
@@ -11,7 +11,6 @@ import (
 	"strings"
 
 	"github.com/vburenin/firempq/conf"
-	"github.com/vburenin/firempq/enc"
 	"github.com/vburenin/firempq/idgen"
 	"github.com/vburenin/firempq/log"
 	"github.com/vburenin/firempq/pqueue"
@@ -238,7 +237,7 @@ func PushAMessage(pq *pqueue.PQueue, senderId string, paramList []string) sqs_re
 	if marshalErr != nil {
 		log.Error("Failed to serialize message payload: %v", err)
 	}
-	payload := enc.UnsafeBytesToString(d)
+	payload := string(d)
 
 	resp := pq.Push(msgId, payload, pq.Config().MsgTtl, out.DelaySeconds, 1)
 	if resp.IsError() {