|
|
@@ -115,7 +115,7 @@ func (receiver Receiver) MmReceive(args Args, reply *Reply) error {
|
|
115
|
115
|
|
|
116
|
116
|
}
|
|
117
|
117
|
}()
|
|
118
|
|
- reply.CompleteLog = "received"
|
|
|
118
|
+ reply.CompleteLog = "WM received"
|
|
119
|
119
|
default:
|
|
120
|
120
|
return errors.New("message type Error: Not registered message type")
|
|
121
|
121
|
}
|
|
|
@@ -169,7 +169,7 @@ func (moscato *Moscato) Receive(msg MsgUnit) (MsgUnit, error) {
|
|
169
|
169
|
go moscato.Send2MS(addr, newMsg)
|
|
170
|
170
|
|
|
171
|
171
|
case WM: //Withdraw msg
|
|
172
|
|
- moscato.MicroServiceManager.RemoveMicroservice(msg.(*WithdrawMsg).From)
|
|
|
172
|
+ moscato.MicroServiceManager.RemoveMicroservice(msg.(WithdrawMsg).From)
|
|
173
|
173
|
|
|
174
|
174
|
default:
|
|
175
|
175
|
return nil, errors.New("Message type Error: Not registered message type")
|