Fixed message ID format

vnalawad-tibco · vnalawad-tibco · commit 3ac935be6416 · 2020-12-22T23:37:58.000-08:00
diff --git a/pulsar/trigger/subscriber/trigger.go b/pulsar/trigger/subscriber/trigger.go
@@ -165,7 +165,7 @@ func (handler *Handler) consume() {
 }
 
 func (handler *Handler) handleMessage(msg pulsar.ConsumerMessage) {
-	handler.handler.Logger().Debugf("Message received - %s", string(msg.ID().Serialize()))
+	handler.handler.Logger().Debugf("Message received - %s", msg.ID())
 	out := &Output{}
 	if handler.handler.Settings()["format"] != nil &&
 		handler.handler.Settings()["format"].(string) == "JSON" {

Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,7 @@ func (handler *Handler) consume() {`
`165`	`165`	`}`
`166`	`166`
`167`	`167`	`func (handler *Handler) handleMessage(msg pulsar.ConsumerMessage) {`
`168`		`- handler.handler.Logger().Debugf("Message received - %s", string(msg.ID().Serialize()))`
	`168`	`+ handler.handler.Logger().Debugf("Message received - %s", msg.ID())`
`169`	`169`	`out := &Output{}`
`170`	`170`	`if handler.handler.Settings()["format"] != nil &&`
`171`	`171`	`handler.handler.Settings()["format"].(string) == "JSON" {`