import (
"errors"
- "routing-manager/pkg/rtmgr"
- "strconv"
-
"nanomsg.org/go/mangos/v2"
"nanomsg.org/go/mangos/v2/protocol/push"
_ "nanomsg.org/go/mangos/v2/transport/all"
+ "routing-manager/pkg/rtmgr"
+ "strconv"
)
type NngPush struct {
func pipeEventHandler(event mangos.PipeEvent, pipe mangos.Pipe) {
rtmgr.Logger.Debug("Invoked: pipeEventHandler()")
+ rtmgr.Logger.Debug("Received pipe event for " + pipe.Address() + " address")
for _, ep := range rtmgr.Eps {
uri := DefaultNngPipelineSocketPrefix + ep.Ip + ":" + strconv.Itoa(DefaultNngPipelineSocketNumber)
if uri == pipe.Address() {