type Consumer struct{}
func (m Consumer) Consume(params *xapp.RMRParams) (err error) {
- xapp.Sdl.Store("myKey", params.Payload)
+ xapp.SdlStorage.Store(rtmgr.RTMGR_SDL_NS, "myKey", params.Payload)
return nil
}
Resets the EndpointList according to argumnets
*/
func resetTestPushDataset(instance RmrPush, testdata []rtmgr.Endpoint) {
+ rtmgr.RMRConnStatus = make(map[string]bool)
rtmgr.Eps = make(map[string]*rtmgr.Endpoint)
for _, endpoint := range testdata {
ep := endpoint