From 141bb0a557c81cb6d1c651b085b3e65483d5e681 Mon Sep 17 00:00:00 2001 From: maxinglun Date: Sun, 10 Apr 2022 10:41:02 +0800 Subject: [PATCH] Revert "Get rid of dependence on 'Micro-Topic'" This reverts commit 3ff69443364d39f5fda3a32fc2249826e2d207dd. --- plugins/broker/rabbitmq/rabbitmq.go | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/plugins/broker/rabbitmq/rabbitmq.go b/plugins/broker/rabbitmq/rabbitmq.go index 9903d13dc8..03244b718d 100644 --- a/plugins/broker/rabbitmq/rabbitmq.go +++ b/plugins/broker/rabbitmq/rabbitmq.go @@ -7,9 +7,9 @@ import ( "sync" "time" - "github.com/streadway/amqp" "go-micro.dev/v4/broker" "go-micro.dev/v4/cmd" + "github.com/streadway/amqp" ) type rbroker struct { @@ -267,13 +267,6 @@ func (r *rbroker) Subscribe(topic string, handler broker.Handler, opts ...broker for k, v := range msg.Headers { header[k], _ = v.(string) } - - // Get rid of dependence on 'Micro-Topic' - msgTopic := header["Micro-Topic"] - if msgTopic == "" { - header["Micro-Topic"] = msg.RoutingKey - } - m := &broker.Message{ Header: header, Body: msg.Body,