update for latest micro

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2021-04-20 14:27:30 +03:00
parent ecca7b7eb9
commit 8c286fb3af
3 changed files with 9 additions and 66 deletions

16
tcp.go
View File

@@ -91,13 +91,11 @@ func (h *tcpServer) NewHandler(handler interface{}, opts ...server.HandlerOption
var eps []*register.Endpoint
if !options.Internal {
for name, metadata := range options.Metadata {
eps = append(eps, &register.Endpoint{
Name: name,
Metadata: metadata,
})
}
for name, metadata := range options.Metadata {
eps = append(eps, &register.Endpoint{
Name: name,
Metadata: metadata,
})
}
th := &tcpHandler{
@@ -167,9 +165,7 @@ func (h *tcpServer) Register() error {
var subscriberList []*tcpSubscriber
for e := range h.subscribers {
// Only advertise non internal subscribers
if !e.Options().Internal {
subscriberList = append(subscriberList, e)
}
subscriberList = append(subscriberList, e)
}
sort.Slice(subscriberList, func(i, j int) bool {
return subscriberList[i].topic > subscriberList[j].topic