Skip to content

Commit b7807bc

Browse files
yuqingyangabrilgzz
authored andcommitted
Add queue in gmo
1 parent e85a070 commit b7807bc

File tree

1 file changed

+8
-0
lines changed
  • Service/GroupMembershipManagement/Hosts/GroupMembershipObtainer/Function

1 file changed

+8
-0
lines changed

Service/GroupMembershipManagement/Hosts/GroupMembershipObtainer/Function/Startup.cs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,14 @@ public override void Configure(IFunctionsHostBuilder builder)
6565
);
6666
})
6767
.AddSingleton<IServiceBusQueueRepository, ServiceBusQueueRepository>(services =>
68+
{
69+
var configuration = services.GetRequiredService<IConfiguration>();
70+
var notificationsQueue = configuration["serviceBusNotificationsQueue"];
71+
var client = services.GetRequiredService<ServiceBusClient>();
72+
var sender = client.CreateSender(notificationsQueue);
73+
return new ServiceBusQueueRepository(sender);
74+
})
75+
.AddSingleton<IServiceBusQueueRepository, ServiceBusQueueRepository>(services =>
6876
{
6977
var configuration = services.GetRequiredService<IConfiguration>();
7078
var membershipAggregatorQueue = configuration["serviceBusMembershipAggregatorQueue"];

0 commit comments

Comments
 (0)