fix for latest micro

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2021-12-16 15:27:02 +03:00
parent 8bcc645147
commit 80842ca667
3 changed files with 11 additions and 7 deletions

View File

@@ -2,19 +2,18 @@ package drpc
import (
"go.unistack.org/micro/v3/client"
"go.unistack.org/micro/v3/metadata"
)
type drpcEvent struct {
payload interface{}
topic string
contentType string
opts client.MessageOptions
}
func newDRPCEvent(topic string, payload interface{}, contentType string, opts ...client.MessageOption) client.Message {
var options client.MessageOptions
for _, o := range opts {
o(&options)
}
options := client.NewMessageOptions(opts...)
if len(options.ContentType) > 0 {
contentType = options.ContentType
@@ -23,6 +22,7 @@ func newDRPCEvent(topic string, payload interface{}, contentType string, opts ..
return &drpcEvent{
payload: payload,
topic: topic,
opts: options,
contentType: contentType,
}
}
@@ -38,3 +38,7 @@ func (d *drpcEvent) Topic() string {
func (d *drpcEvent) Payload() interface{} {
return d.payload
}
func (d *drpcEvent) Metadata() metadata.Metadata {
return d.opts.Metadata
}