Rename local to queue

LukeButters · LukeButters · commit 1403f35b3bbb · 2026-01-08T10:01:44.000+11:00
diff --git a/source/Halibut.Tests/RPCOverQueueExecutionModeFixture.cs b/source/Halibut.Tests/RPCOverQueueExecutionModeFixture.cs
@@ -51,16 +51,16 @@ public async Task SimpleRPCOverQueueExecutionExample()
                 .WithHalibutTimeoutsAndLimits(timeoutsAndLimits)
                 .Build();
 
-            // Start worker polling for local://test-worker
+            // Start worker polling
             using var workerCts = new CancellationTokenSource();
             var pollingTask = Task.Run(async () =>
             {
-                await worker.PollForRPCOverQueueAsync(new Uri("local://test-worker"), workerCts.Token);
+                await worker.PollForRPCOverQueueAsync(new Uri(HalibutRuntime.QueueEndpointScheme + "://test-worker"), workerCts.Token);
             }, workerCts.Token);
 
-            // Client creates proxy to local://test-worker and makes request
+            // Client creates proxy and makes request
             var echo = client.CreateAsyncClient<IEchoService, IAsyncClientEchoService>(
-                new ServiceEndPoint("local://test-worker", null, client.TimeoutsAndLimits));
+                new ServiceEndPoint(HalibutRuntime.QueueEndpointScheme + "://test-worker", null, client.TimeoutsAndLimits));
 
             var result = await echo.SayHelloAsync("World");
             result.Should().Be("World...");
diff --git a/source/Halibut/HalibutRuntime.cs b/source/Halibut/HalibutRuntime.cs
@@ -21,7 +21,7 @@ namespace Halibut
 {
     public class HalibutRuntime : IHalibutRuntime
     {
-        public const string QueueEndpointScheme = "local";
+        public const string QueueEndpointScheme = "queue";
         public static readonly string DefaultFriendlyHtmlPageContent = "<html><body><p>Hello!</p></body></html>";
         readonly ConcurrentDictionary<Uri, IPendingRequestQueue> queues = new();
         readonly IPendingRequestQueueFactory queueFactory;
@@ -204,7 +204,7 @@ public async Task PollForRPCOverQueueAsync(Uri queueOnlyEndpoint, CancellationTo
         {
             if (queueOnlyEndpoint.Scheme.ToLowerInvariant() != QueueEndpointScheme)
             {
-                throw new ArgumentException($"Only 'queue://' endpoints are supported. Provided: {queueOnlyEndpoint.Scheme}://", nameof(queueOnlyEndpoint));
+                throw new ArgumentException($"Only '{QueueEndpointScheme}://' endpoints are supported. Provided: {queueOnlyEndpoint.Scheme}://", nameof(queueOnlyEndpoint));
             }
 
             var queue = GetQueue(queueOnlyEndpoint);

Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ namespace Halibut`
`21`	`21`	`{`
`22`	`22`	`public class HalibutRuntime : IHalibutRuntime`
`23`	`23`	`{`
`24`		`- public const string QueueEndpointScheme = "local";`
	`24`	`+ public const string QueueEndpointScheme = "queue";`
`25`	`25`	`public static readonly string DefaultFriendlyHtmlPageContent = "<html><body><p>Hello!</p></body></html>";`
`26`	`26`	`readonly ConcurrentDictionary<Uri, IPendingRequestQueue> queues = new();`
`27`	`27`	`readonly IPendingRequestQueueFactory queueFactory;`
`@@ -204,7 +204,7 @@ public async Task PollForRPCOverQueueAsync(Uri queueOnlyEndpoint, CancellationTo`
`204`	`204`	`{`
`205`	`205`	`if (queueOnlyEndpoint.Scheme.ToLowerInvariant() != QueueEndpointScheme)`
`206`	`206`	`{`
`207`		`- throw new ArgumentException($"Only 'queue://' endpoints are supported. Provided: {queueOnlyEndpoint.Scheme}://", nameof(queueOnlyEndpoint));`
	`207`	`+ throw new ArgumentException($"Only '{QueueEndpointScheme}://' endpoints are supported. Provided: {queueOnlyEndpoint.Scheme}://", nameof(queueOnlyEndpoint));`
`208`	`208`	`}`
`209`	`209`
`210`	`210`	`var queue = GetQueue(queueOnlyEndpoint);`