Simplified QueueManager.Subscribe

Author: stidsborg

.claude/settings.local.json

@@ -32,7 +32,10 @@
       "Bash(rm -f /tmp/messaging-tests.log)",
       "Bash(dotnet test *)",
       "Read(//private/tmp/**)",
-      "Bash(gh pr *)"
+      "Bash(gh pr *)",
+      "Read(//Users/stidsborg/.claude/**)",
+      "mcp__rider__find_files_by_name_keyword",
+      "mcp__rider__search_in_files_by_regex"
     ],
     "deny": [],
     "ask": []

Core/Cleipnir.ResilientFunctions/Queuing/QueueClient.cs

@@ -58,11 +58,7 @@ public Task<Envelope> PullEnvelope<T>(Workflow workflow, EffectId parentId, Func
             return await queueManager.Subscribe(
                 envelope => filter?.Invoke(envelope) ?? true,
                 timeout,
-                timeoutId,
                 messageId,
-                messageTypeId,
-                receiverId,
-                senderId,
                 captureMessage: msg =>
                     msg == null
                         ? [EffectResult.Create(messageId, null)]

Core/Cleipnir.ResilientFunctions/Queuing/QueueManager.cs

@@ -128,11 +128,7 @@ internal void Interrupt()
     public async Task<Envelope?> Subscribe(
         MessagePredicate predicate,
         DateTime? timeout,
-        EffectId timeoutId,
         EffectId messageId,
-        EffectId messageTypeId,
-        EffectId receiverId,
-        EffectId senderId,
         Func<MessageData?, IEnumerable<EffectResult>> captureMessage)
     {
         if (_thrownException is { } pre)