feat(server,connector): add test code for acknowledgements

src/docker/Thinktecture.Relay.Connector.Docker/Startup.cs

@@ -5,10 +5,13 @@
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
+using System.Web;
+using Microsoft.AspNetCore.Http.Extensions;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using Thinktecture.Relay.Acknowledgement;
 using Thinktecture.Relay.Connector.Targets;
 using Thinktecture.Relay.Transport;
 
@@ -62,6 +65,13 @@ public async Task<TargetResponse> HandleAsync(ClientRequest request, Cancellatio
 			}
 		}
 
+		// Test: If we wait with ack for a completed target request, delay a bit to be able to restart rabbit
+		var url = $"http://localhorst/{request.Url}";
+		if (TimeSpan.TryParse(HttpUtility.ParseQueryString(new Uri(url).Query).Get("delay"), out var delay))
+		{
+			await Task.Delay(delay, cancellationToken);
+		}
+
 		var response = request.CreateResponse();
 
 		response.HttpStatusCode = HttpStatusCode.OK;

src/docker/Thinktecture.Relay.Server.Docker/Interceptors/ConnectorFinishedAcknowledgementModeInterceptor.cs

@@ -0,0 +1,18 @@
+using System.Threading;
+using System.Threading.Tasks;
+using Thinktecture.Relay.Acknowledgement;
+using Thinktecture.Relay.Server.Interceptor;
+using Thinktecture.Relay.Server.Transport;
+using Thinktecture.Relay.Transport;
+
+namespace Thinktecture.Relay.Server.Docker.Interceptors;
+
+public class ConnectorFinishedAcknowledgementModeInterceptor : IClientRequestInterceptor<ClientRequest, TargetResponse>
+{
+	public Task OnRequestReceivedAsync(IRelayContext<ClientRequest, TargetResponse> context,
+		CancellationToken cancellationToken = default)
+	{
+		context.ClientRequest.AcknowledgeMode = AcknowledgeMode.Manual;
+		return Task.CompletedTask;
+	}
+}