subId := m.subIds[0]
subscriptionInfo := &SubscriptionInfo{}
err := json.Unmarshal([]byte(val), subscriptionInfo)
subId := m.subIds[0]
subscriptionInfo := &SubscriptionInfo{}
err := json.Unmarshal([]byte(val), subscriptionInfo)
delete(m.register, subId)
m.subIds = append(m.subIds, subId)
return nil
delete(m.register, subId)
m.subIds = append(m.subIds, subId)
return nil
subId64, err := strconv.ParseUint(key, 10, 64)
if err != nil {
return fmt.Errorf("RemoveAll() ParseUint() error: %s\n", err.Error())
}
subId := uint32(subId64)
subId64, err := strconv.ParseUint(key, 10, 64)
if err != nil {
return fmt.Errorf("RemoveAll() ParseUint() error: %s\n", err.Error())
}
subId := uint32(subId64)
delete(m.register, subId)
m.subIds = append(m.subIds, subId)
}
delete(m.register, subId)
m.subIds = append(m.subIds, subId)
}