[plus]MM_Receive

src/broker/modules/init.go

@@ -30,55 +30,57 @@ type Moscato struct {
 	secure_mng secure_manager
 }
 
-type MicroService struct {
-	receivemsg *SubscriptionMsg
+type Reply struct {
+	ReceiveMsg MsgUnit
 }
 
-//Recieve - MM가 msg전달 받음
-func (moscato *Moscato) Recieve(msg MsgUnit) (MsgUnit, error) {
-	msg_type := msg.CheckType()
+type Listner int
+
+
+//MS에서 보내는거-rpc call 사용
+/*func (l *Listner)MM_Receive(msg MsgUnit, reply *Reply)error{
+	reply.ReceiveMsg=msg
+
+	return nil
+}*/
+
+func (moscato *Moscato)MM_Receive(msg MsgUnit, reply *Reply)error{
+	reply.ReceiveMsg=msg
+  	go moscato.Receive(reply)
+	return nil
+}
 
+//Recieve - MM가 msg전달 받음
+func (moscato *Moscato)Receive(reply *Reply) (MsgUnit, error) {
+	//rpc call
+	var msg_type = reply.ReceiveMsg.CheckType()
 	//메세지 타입에 따라 다르게 처리
 	switch msg_type {
 
 	case KSM: //Key share msg
 
 	case PM: //Publish msg
-		moscato.queue.push(msg.(*PublishMsg))
+		moscato.queue.push(reply.ReceiveMsg.(*PublishMsg))
 
 	case SM: //Subscription msg
-		moscato.match_mng.add_subscription(msg.(*SubscriptionMsg))
+		moscato.match_mng.add_subscription(reply.ReceiveMsg.(*SubscriptionMsg))
 
 	case RM: //Register msg
 		//var newmsg RegisterMsg
-		var newmsg = msg.(*RegisterMsg)
+		var newmsg = reply.ReceiveMsg.(*RegisterMsg)
 		newNode := MSnode{newmsg.From(), newmsg.From()}
 		moscato.ms_mng.add_microservice(newNode)
 
 	case WM: //Withdraw msg
-		moscato.ms_mng.remove_microservice(msg.(*WithdrawMsg).From())
+		moscato.ms_mng.remove_microservice(reply.ReceiveMsg.(*WithdrawMsg).From())
 
 	default:
 		return nil, errors.New("Message type Error: Not registered message type")
 	}
 
-	return msg, nil
+	return reply.ReceiveMsg, nil
 }
 
-//Receive - MicorService가 msg 받음// MS.go들어가야할 함수
-/*func (ms *MicroService)Receive(msg MsgUnit)error{
-	msg_type:=msg.CheckType()
-
-	switch msg_type{
-	case KGM://Key Gen Msg
-
-	case KSM://Key Share Msg
-
-	case SM://Subscription Msg
-		ms.receivemsg=msg.(*SubscriptionMsg)
-	}
-	return nil
-}*/
 
 func (moscato *Moscato) Run() {
 	//모스카토 구조체 변수 초기화