From a5b70e9476d289c6fe8e955b2e31451cceafcafa Mon Sep 17 00:00:00 2001
From: Eldad Fux <eldad.fux@gmail.com>
Date: Tue, 9 Mar 2021 19:27:48 +0200
Subject: [PATCH] Fixed registry contex

---
 app/realtime.php | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/app/realtime.php b/app/realtime.php
index b1c34266c..3030837e7 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -39,12 +39,12 @@ $subscriptions = [];
 $connections = [];
 
 $server->on('workerStart', function ($server, $workerId) use (&$subscriptions, &$connections, &$register) {
-    Console::success('Worker ' . ++$workerId . ' started succefully');
+    Console::success('Worker ' . $workerId . ' started succefully');
     
     $attempts = 0;
     $start = time();
 
-    // $register->context('realtime-' . $workerId);
+    $register->context('realtime-pubsub-' . $workerId);
 
     while ($attempts < 300) {
         try {
@@ -121,6 +121,8 @@ $server->on('start', function (Server $server) {
 $server->on('open', function (Server $server, Request $request) use (&$connections, &$subscriptions, &$register) {
     Console::info("Connection open (user: {$request->fd}, connections: {}, worker: {$server->getWorkerId()})");
 
+    $register->context('realtime-' . $server->getWorkerId());
+
     $app = new App('');
     $connection = $request->fd;
     $request = new SwooleRequest($request);