unistack-org/micro-server-tcp
4
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 13 Wiki Activity

fix for latest micro

Browse Source 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов
2020-11-03 02:14:32 +03:00
parent ee43cf6349
commit 4585a4fb9a
3 changed files with 25 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tcp.go
View File

@@ -9,10 +9,10 @@ import (
"sync"
"time"
jsonrpc "github.com/unistack-org/micro-codec-jsonrpc"
protorpc "github.com/unistack-org/micro-codec-protorpc"
"github.com/unistack-org/micro/v3/broker"
"github.com/unistack-org/micro/v3/codec"
jsonrpc "github.com/unistack-org/micro/v3/codec/jsonrpc"
protorpc "github.com/unistack-org/micro/v3/codec/protorpc"
"github.com/unistack-org/micro/v3/logger"
"github.com/unistack-org/micro/v3/registry"
"github.com/unistack-org/micro/v3/server"
@@ -170,7 +170,7 @@ func (h *tcpServer) Register() error {
logger.Infof("Registering node: %s", opts.Name+"-"+opts.Id)
})
if err := opts.Registry.Register(service, rOpts...); err != nil {
if err := opts.Registry.Register(opts.Context, service, rOpts...); err != nil {
return err
}
@@ -217,7 +217,7 @@ func (h *tcpServer) Deregister() error {
if err != nil {
return err
}
if err := opts.Registry.Deregister(service); err != nil {
if err := opts.Registry.Deregister(opts.Context, service); err != nil {
return err
}