Skip to content

Commit 1eeeacb

Browse files
authored
Merge pull request #134 from TraGicCode/chore/fix-transport-issue-where-sendonly-endpoints-are-creating-receievers
Fix SendOnly transports creating receivers
2 parents bffdb3a + d36c01c commit 1eeeacb

File tree

2 files changed

+15
-13
lines changed

2 files changed

+15
-13
lines changed

src/BuslyCLI.Console/Factories/RawEndpointFactory.cs

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -163,16 +163,18 @@ private static async Task<TransportInfrastructure> InternalCreateInfrastructure(
163163
},
164164
isReceiveEnabled);
165165

166-
167-
var infrastructure = await transport.Initialize(hostSettings, new[]
168-
{
169-
new ReceiveSettings(
170-
"Primary",
171-
new QueueAddress(endpointName),
172-
isReceiveEnabled,
173-
false,
174-
"error")
175-
}, new string[0]);
166+
var infrastructure = await transport.Initialize(hostSettings,
167+
isReceiveEnabled
168+
?
169+
[
170+
new ReceiveSettings(
171+
"Primary",
172+
new QueueAddress(endpointName),
173+
isReceiveEnabled,
174+
false,
175+
"error")
176+
]
177+
: [], []);
176178

177179

178180
return infrastructure;

tests/BuslyCLI.Console.Tests/EndToEnd/Infrastructure/ITestEndpointFactory.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,15 +78,15 @@ private static async Task<TestEndpoint> InternalCreateTestEndpoint(string endpoi
7878
// TODO: This needs to be false for "Azure Service Bus Emulator" tests to pass
7979
transport is not AzureServiceBusTransport);
8080

81-
var infrastructure = await transport.Initialize(hostSettings, new[]
82-
{
81+
var infrastructure = await transport.Initialize(hostSettings, [
8382
new ReceiveSettings(
8483
"Primary",
8584
new QueueAddress(endpointName),
8685
true,
8786
false,
8887
"error")
89-
}, new string[0]);
88+
], []);
89+
9090

9191
return new TestEndpoint(infrastructure);
9292
}

0 commit comments

Comments
 (0)