From 2fa602f55775917155a3d0797680a3af12a68eef Mon Sep 17 00:00:00 2001 From: "Tobias Wellnitz, DH1TW" Date: Sat, 13 Jul 2019 22:35:31 +0200 Subject: [PATCH] fixed more micro API changes --- cmd/client_nats.go | 1 + cmd/server_nats.go | 2 +- trx/trx.go | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/cmd/client_nats.go b/cmd/client_nats.go index 6a478bc..8aa495e 100644 --- a/cmd/client_nats.go +++ b/cmd/client_nats.go @@ -21,6 +21,7 @@ import ( "github.com/micro/go-micro/client" "github.com/micro/go-micro/registry" "github.com/micro/go-micro/transport" + "github.com/micro/go-micro/client/selector/static" natsBroker "github.com/micro/go-plugins/broker/nats" natsReg "github.com/micro/go-plugins/registry/nats" natsTr "github.com/micro/go-plugins/transport/nats" // _ "net/http/pprof" diff --git a/cmd/server_nats.go b/cmd/server_nats.go index 9bbb4c2..288e304 100644 --- a/cmd/server_nats.go +++ b/cmd/server_nats.go @@ -370,7 +370,7 @@ type natsServer struct { lastPing time.Time } -func (ns *natsServer) enqueueFromWire(pub broker.Publication) error { +func (ns *natsServer) enqueueFromWire(pub broker.Event) error { if ns.fromNetwork == nil { return nil } diff --git a/trx/trx.go b/trx/trx.go index 11b5135..9dfe15d 100644 --- a/trx/trx.go +++ b/trx/trx.go @@ -334,7 +334,7 @@ func (x *Trx) TxUser() (string, error) { // fromWireCb is a callback that is executed when audio is received // from the network. It will typically then enqueue the received data // into an audio source / chain. -func (x *Trx) fromWireCb(pub broker.Publication) error { +func (x *Trx) fromWireCb(pub broker.Event) error { x.RLock() defer x.RUnlock()