Skip to content

Commit 15aa401

Browse files
committed
Remove the file reading
1 parent fd1a62e commit 15aa401

File tree

1 file changed

+5
-19
lines changed

1 file changed

+5
-19
lines changed

src/Helper/BusRegistrationConfiguratorExt.cs

Lines changed: 5 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -9,27 +9,13 @@ public static void SetupTransport(this IBusRegistrationConfigurator x, string[]
99

1010
switch (selectedTransport)
1111
{
12-
case "AmazonSQS":
13-
x.UsingAmazonSqs((ctx, cfg) =>
14-
{
15-
var envs = DotEnv.Read(new DotEnvOptions(envFilePaths: [Path.GetFullPath("../../../sqs.env")]));
16-
cfg.Host(envs["AWS_REGION"], h =>
17-
{
18-
h.AccessKey(envs["AWS_ACCESS_KEY_ID"]);
19-
h.SecretKey(envs["AWS_SECRET_ACCESS_KEY"]);
20-
});
21-
22-
cfg.ConfigureEndpoints(ctx);
23-
});
24-
break;
2512
case "AzureServiceBus":
26-
var envs = DotEnv.Read(new DotEnvOptions(envFilePaths: [Path.GetFullPath("../../../asb.env")], ignoreExceptions: false));
13+
string connectionString = Environment.GetEnvironmentVariable("CONNECTION_STRING");
2714
x.UsingAzureServiceBus((context, cfg) =>
28-
{
29-
cfg.Host(envs["CONNECTION_STRING"]);
30-
31-
cfg.ConfigureEndpoints(context);
32-
});
15+
{
16+
cfg.Host(connectionString);
17+
cfg.ConfigureEndpoints(context);
18+
});
3319
break;
3420
case "RabbitMQ":
3521
x.UsingRabbitMq((context, cfg) =>

0 commit comments

Comments
 (0)