fixed more micro API changes

dh1tw · Jul 13, 2019 · 2fa602f · 2fa602f
1 parent 46f9178
commit 2fa602f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git 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
@@ -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
@@ -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()