diff --git a/service/natsService.go b/service/natsService.go
index 18bf0d8..77e5bdf 100644
--- a/service/natsService.go
+++ b/service/natsService.go
@@ -143,7 +143,7 @@ func (s *NatsService) Call(rpcTopic string, msg *ipb.InternalMsg, cb func(msg *i
 	if err != nil {
 		return err
 	}
-	s.rpcProcessor.RegisterMessage(msg.RetRpcMsgId, ipb.InternalMsg{}, cb)
+	s.RegisterRpcMessage(msg.RetRpcMsgId, cb)
 	return nil
 }