go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2025-07-12 22:41:07 +02:00
Code Issues Releases Activity

Revert "Get rid of dependence on 'Micro-Topic'"

Browse Source 
This reverts commit 3ff6944336.
This commit is contained in:
maxinglun
2022-04-10 10:41:02 +08:00
parent 3ff6944336
commit 141bb0a557
1 changed files with 1 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
plugins/broker/rabbitmq/rabbitmq.go
View File

@ -7,9 +7,9 @@ import (
"sync" "sync"
"time" "time"
"github.com/streadway/amqp"
"go-micro.dev/v4/broker" "go-micro.dev/v4/broker"
"go-micro.dev/v4/cmd" "go-micro.dev/v4/cmd"
"github.com/streadway/amqp"
) )
type rbroker struct { type rbroker struct {
@ -267,13 +267,6 @@ func (r *rbroker) Subscribe(topic string, handler broker.Handler, opts ...broker
for k, v := range msg.Headers { for k, v := range msg.Headers {
header[k], _ = v.(string) 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{ m := &broker.Message{
Header: header, Header: header,
Body: msg.Body, Body: msg.Body,