"strings"
)
-const DefaultNngPipelineSocketPrefix = "tcp://"
-const DefaultNngPipelineSocketNumber = 4561
+const DefaultRmrPipelineSocketPrefix = "tcp://"
+const DefaultRmrPipelineSocketNumber = 4561
const PlatformType = "platform"
var (
SupportedSbis = []*EngineConfig{
{
- Name: "nngpush",
+ Name: "rmrpush",
Version: "v1",
- Protocol: "nngpipeline",
- Instance: NewNngPush(),
+ Protocol: "rmrpipeline",
+ Instance: NewRmrPush(),
IsAvailable: true,
},
}
sbi.DeleteEndpoint(ep)
delete(rtmgr.Eps, ep.Uuid)
} else {
- rtmgr.Eps[ep.Uuid].Keepalive = false
+ if rtmgr.Eps[ep.Uuid] != nil {
+ rtmgr.Eps[ep.Uuid].Keepalive = false
+ }
}
}
}
XAppType: PlatformType,
Ip: pc.Fqdn,
Port: pc.Port,
- TxMessages: rtmgr.PLATFORMMESSAGETYPES[pc.Name]["tx"],
- RxMessages: rtmgr.PLATFORMMESSAGETYPES[pc.Name]["rx"],
+ //TxMessages: rtmgr.PLATFORMMESSAGETYPES[pc.Name]["tx"],
+ //RxMessages: rtmgr.PLATFORMMESSAGETYPES[pc.Name]["rx"],
Socket: nil,
IsReady: false,
Keepalive: true,
XAppType: PlatformType,
Ip: ipaddress,
Port: uint16(port),
- TxMessages: rtmgr.PLATFORMMESSAGETYPES[e2t.Name]["tx"],
- RxMessages: rtmgr.PLATFORMMESSAGETYPES[e2t.Name]["rx"],
+ //TxMessages: rtmgr.PLATFORMMESSAGETYPES[e2t.Name]["tx"],
+ //RxMessages: rtmgr.PLATFORMMESSAGETYPES[e2t.Name]["rx"],
Socket: nil,
IsReady: false,
Keepalive: true,