Merge pull request #41 from Comcast/fix/change-wrp-to-msgpack

Change content-type wrp to msgpack.
xmidt-org · Aug 10, 2017 · f19501d · f19501d
2 parents bd79611 + 37a0eac
commit f19501d
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/caduceus/outboundSender.go b/src/caduceus/outboundSender.go
@@ -333,7 +333,7 @@ func (obs *CaduceusOutboundSender) QueueWrp(req CaduceusRequest, metaData map[st
 							event:       eventType,
 							transID:     transID,
 							deviceID:    deviceID,
-							contentType: "application/wrp",
+							contentType: "application/msgpack",
 						}
 						outboundReq.req.Telemetry.TimeOutboundAccepted = time.Now()
 						obs.queue <- outboundReq

diff --git a/src/caduceus/senderWrapper.go b/src/caduceus/senderWrapper.go
@@ -156,7 +156,7 @@ func (sw *CaduceusSenderWrapper) Queue(req CaduceusRequest) {
 			}
 		}
 
-	case "application/wrp":
+	case "application/msgpack":
 		decoder := wrp.NewDecoderBytes(req.Payload, wrp.Msgpack)
 		message := new(wrp.Message)
 		if err := decoder.Decode(message); nil == err {

diff --git a/src/caduceus/senderWrapper_test.go b/src/caduceus/senderWrapper_test.go
@@ -97,7 +97,7 @@ func TestSwSimple(t *testing.T) {
 	}
 	wrp := CaduceusRequest{
 		Payload:     buffer.Bytes(),
-		ContentType: "application/wrp",
+		ContentType: "application/msgpack",
 		TargetURL:   "http://foo.com/api/v2/notify/mac:112233445566/event/wrp",
 	}