1 files changed, 4 insertions, 0 deletions

diff --git a/internal/handler/grpc/server.go b/internal/handler/grpc/server.go
index 74857f6..b65b527 100644
--- a/internal/handler/grpc/server.go
+++ b/internal/handler/grpc/server.go
@@ -28,6 +28,10 @@ func NewServer(store EventStore) *Server {
         }
 }
 
+func (s *Server) SetSubscriptionManager(mgr *subscription.Manager) {
+        s.subs = mgr
+}
+
 func (s *Server) PublishEvent(ctx context.Context, req *pb.PublishEventRequest) (*pb.PublishEventResponse, error) {
         if req.Event == nil {
                 return &pb.PublishEventResponse{