-

GuGoOrg · Aug 30, 2023 · 9b4e0d6 · 9b4e0d6
1 parent 558abed
commit 9b4e0d6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/constant/strings/service.go b/src/constant/strings/service.go
@@ -13,5 +13,5 @@ const (
 	VideoCommentEvent   = "video.comment.action"
 	VideoPublishEvent   = "video.publish.action"
 
-	MessageActionEvent = "message_send"
+	MessageActionEvent = "message.send"
 )
diff --git a/src/services/message/handler.go b/src/services/message/handler.go
@@ -65,14 +65,17 @@ func (c MessageServiceImpl) New() {
 		failOnError(err, "Failed to open a channel")
 	}
 
-	channel.ExchangeDeclare(
+	err = channel.ExchangeDeclare(
 		strings.MessageExchange,
 		"x-delayed-message",
 		true, false, false, false,
 		amqp.Table{
 			"x-delayed-type": "direct",
 		},
 	)
+	if err != nil {
+		failOnError(err, "Failed to get exchange")
+	}
 
 	_, err = channel.QueueDeclare(
 		strings.MessageActionEvent,