Record RPC groups according to service and method

deriv-com · Jun 6, 2024 · 86b68d1 · 86b68d1
1 parent 332095b
commit 86b68d1
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/lib/Myriad/RPC/Implementation/Redis.pm b/lib/Myriad/RPC/Implementation/Redis.pm
@@ -98,9 +98,10 @@ async method create_group ($rpc) {
             '0',
             1
         );
-        await $redis->hset(
-            'rpc.group',
-            $rpc->{stream},
+        my ($service, $method) = service_from_stream_name($rpc->{stream});
+        await $self->redis->hset(
+            "rpc.group.{$service}",
+            $method,
             $self->group_name,
         );
         $rpc->{group} = 1;