Merge remote-tracking branch 'origin/master'

src/broker/modules/init.go

@@ -30,13 +30,11 @@ type Moscato struct {
 	secure_mng secure_manager
 }
 
-// Send - rpc를 이용하여 msg전송
-func (moscato *Moscato)Send(ipaddr string, message MsgUnit, reply []byte)([]byte, error) {
-	reply,err:=message.ConvertToJson()
-	return reply,err
+type MicroService struct {
+	receivemsg *SubscriptionMsg
 }
 
-// Recieve - rpc를 이용하여 msg전달 받음(rpc call)
+//Recieve - MM가 msg전달 받음
 func (moscato *Moscato) Recieve(msg MsgUnit) (MsgUnit, error) {
 	msg_type := msg.CheckType()
 
@@ -54,11 +52,11 @@ func (moscato *Moscato) Recieve(msg MsgUnit) (MsgUnit, error) {
 	case RM: //Register msg
 		//var newmsg RegisterMsg
 		var newmsg = msg.(*RegisterMsg)
-		newNode := MSnode{newmsg.from, newmsg.from}
+		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(msg.(*WithdrawMsg).From())
 
 	default:
 		return nil, errors.New("Message type Error: Not registered message type")
@@ -67,6 +65,21 @@ func (moscato *Moscato) Recieve(msg MsgUnit) (MsgUnit, error) {
 	return msg, 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() {
 	//모스카토 구조체 변수 초기화
 	moscato.queue.queue_init()