Update to checkif sendOnly config is on

Particular · Sep 5, 2023 · cb1ee00 · cb1ee00
1 parent 1df2f4d
commit cb1ee00
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/...us.AzureFunctions.InProcess.ServiceBus/Serverless/TransportWrapper/ServerlessTransport.cs b/...us.AzureFunctions.InProcess.ServiceBus/Serverless/TransportWrapper/ServerlessTransport.cs
@@ -9,6 +9,7 @@ class ServerlessTransport : TransportDefinition
     {
         // HINT: This constant is defined in NServiceBus but is not exposed
         const string MainReceiverId = "Main";
+        const string SendOnlyConfigKey = "Endpoint.SendOnly";
 
         public ServerlessTransport(AzureServiceBusTransport baseTransport) : base(
             baseTransport.TransportTransactionMode,
@@ -32,9 +33,11 @@ public override async Task<TransportInfrastructure> Initialize(HostSettings host
 
             var serverlessTransportInfrastructure = new ServerlessTransportInfrastructure(baseTransportInfrastructure);
 
-            PipelineInvoker = receivers.Length > 0
-                ? (PipelineInvoker)serverlessTransportInfrastructure.Receivers[MainReceiverId]
-                : new PipelineInvoker(new SendOnlyReceiver()); // send-only endpoint
+            var isSendOnly = hostSettings.CoreSettings.GetOrDefault<bool>(SendOnlyConfigKey);
+
+            PipelineInvoker = isSendOnly
+                ? new PipelineInvoker(new SendOnlyReceiver()) // send-only endpoint
+                : (PipelineInvoker)serverlessTransportInfrastructure.Receivers[MainReceiverId];
 
             return serverlessTransportInfrastructure;
         }