|
|
@@ -34,8 +34,8 @@ type MicroService struct {
|
|
34
|
34
|
receivemsg *SubscriptionMsg
|
|
35
|
35
|
}
|
|
36
|
36
|
|
|
37
|
|
-//MM_Recieve - MM가 msg전달 받음
|
|
38
|
|
-func (moscato *Moscato) MM_Recieve(msg MsgUnit) (MsgUnit, error) {
|
|
|
37
|
+//Recieve - MM가 msg전달 받음
|
|
|
38
|
+func (moscato *Moscato) Recieve(msg MsgUnit) (MsgUnit, error) {
|
|
39
|
39
|
msg_type := msg.CheckType()
|
|
40
|
40
|
|
|
41
|
41
|
//메세지 타입에 따라 다르게 처리
|
|
|
@@ -65,8 +65,8 @@ func (moscato *Moscato) MM_Recieve(msg MsgUnit) (MsgUnit, error) {
|
|
65
|
65
|
return msg, nil
|
|
66
|
66
|
}
|
|
67
|
67
|
|
|
68
|
|
-//MS_Receive - MicorService가 msg 받음// MS.go들어가야할 함수
|
|
69
|
|
-/*func (ms *MicroService)MS_Receive(msg MsgUnit)error{
|
|
|
68
|
+//Receive - MicorService가 msg 받음// MS.go들어가야할 함수
|
|
|
69
|
+/*func (ms *MicroService)Receive(msg MsgUnit)error{
|
|
70
|
70
|
msg_type:=msg.CheckType()
|
|
71
|
71
|
|
|
72
|
72
|
switch msg_type{
|