Skip to content

Commit cb1ee00

Browse files
committed
Update to checkif sendOnly config is on
1 parent 1df2f4d commit cb1ee00

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

src/NServiceBus.AzureFunctions.InProcess.ServiceBus/Serverless/TransportWrapper/ServerlessTransport.cs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ class ServerlessTransport : TransportDefinition
99
{
1010
// HINT: This constant is defined in NServiceBus but is not exposed
1111
const string MainReceiverId = "Main";
12+
const string SendOnlyConfigKey = "Endpoint.SendOnly";
1213

1314
public ServerlessTransport(AzureServiceBusTransport baseTransport) : base(
1415
baseTransport.TransportTransactionMode,
@@ -32,9 +33,11 @@ public override async Task<TransportInfrastructure> Initialize(HostSettings host
3233

3334
var serverlessTransportInfrastructure = new ServerlessTransportInfrastructure(baseTransportInfrastructure);
3435

35-
PipelineInvoker = receivers.Length > 0
36-
? (PipelineInvoker)serverlessTransportInfrastructure.Receivers[MainReceiverId]
37-
: new PipelineInvoker(new SendOnlyReceiver()); // send-only endpoint
36+
var isSendOnly = hostSettings.CoreSettings.GetOrDefault<bool>(SendOnlyConfigKey);
37+
38+
PipelineInvoker = isSendOnly
39+
? new PipelineInvoker(new SendOnlyReceiver()) // send-only endpoint
40+
: (PipelineInvoker)serverlessTransportInfrastructure.Receivers[MainReceiverId];
3841

3942
return serverlessTransportInfrastructure;
4043
}

0 commit comments

Comments
 (0)