diff --git a/service/default/p2p.go b/service/default/p2p.go
index e56c6ad..c1ce403 100644
--- a/service/default/p2p.go
+++ b/service/default/p2p.go
@@ -446,6 +446,12 @@ func (p *P2PServiceDefault) OnNewPeerListen(peer net.Peer, verifyId bool) {
 			}),
 		}
 
+		if mediator, ok := data.Mediator.(service.Service); ok {
+			mediator.SetServices(p.Services())
+		} else {
+			p.Logger().Fatal("failed to cast mediator to service.Service")
+		}
+
 		dec := msgpack.NewDecoder(bytes.NewReader(reader.Data))
 
 		err = handler.DecodeMessage(dec, data)