|
|
@@ -181,7 +181,7 @@ func (moscato *Moscato) Receive(msg MsgUnit) (MsgUnit, error) {
|
|
181
|
181
|
go moscato.Send2MS(addr, newMsg)
|
|
182
|
182
|
|
|
183
|
183
|
case WM: //Withdraw msg
|
|
184
|
|
- fromNodeName, _ := moscato.MicroServiceManager.GetIpaddr(msg.(RegisterMsg).From)
|
|
|
184
|
+ fromNodeName, _ := moscato.MicroServiceManager.GetIpaddr(msg.(WithdrawMsg).From)
|
|
185
|
185
|
logger.Info("WM received from:[" + fromNodeName + "]")
|
|
186
|
186
|
//ip := msg.(WithdrawMsg).From
|
|
187
|
187
|
//sublist := moscato.SubscriptionManager.ip2sub[ip]
|