mirror of
https://github.com/go-micro/go-micro.git
synced 2025-06-30 22:33:49 +02:00
Get rid of dependence on 'Micro-Topic'
This commit is contained in:
@ -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,6 +267,13 @@ 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,
|
||||||
|
Reference in New Issue
Block a user