fix the connection string name for trigger

hardik-desai-nhs · hardik-desai-nhs · commit ba5ed16be475 · 2026-04-27T17:25:57.000+01:00
diff --git a/application/CohortManager/src/Functions/AuditServices/AuditWriter/AuditWriter.cs b/application/CohortManager/src/Functions/AuditServices/AuditWriter/AuditWriter.cs
@@ -24,7 +24,7 @@ public AuditWriter(DataServicesContext dbContext, ILogger<AuditWriter> logger)
 
     [Function(nameof(AuditWriter))]
     public async Task Run(
-        [ServiceBusTrigger(topicName: "%AuditTopicName%", subscriptionName: "%AuditSubscription%", Connection = "ServiceBusConnectionString_client_internal")] string messageText, FunctionContext context)
+        [ServiceBusTrigger(topicName: "%AuditTopicName%", subscriptionName: "%AuditSubscription%", Connection = "ServiceBusConnectionString_internal")] string messageText, FunctionContext context)
     {
         ParticipantAuditMessage? audit;
         try
diff --git a/application/CohortManager/src/Functions/CohortDistributionServices/DistributeParticipant/DistributeParticipant.cs b/application/CohortManager/src/Functions/CohortDistributionServices/DistributeParticipant/DistributeParticipant.cs
@@ -35,7 +35,7 @@ public DistributeParticipant(ILogger<DistributeParticipant> logger, IOptions<Dis
     /// <returns></returns>
     [Function("DistributeParticipant")]
     public async Task Run(
-   [ServiceBusTrigger(topicName: "%CohortDistributionTopic%", subscriptionName: "%DistributeParticipantSubscription%", Connection = "ServiceBusConnectionString_client_internal")]
+    [ServiceBusTrigger(topicName: "%CohortDistributionTopic%", subscriptionName: "%DistributeParticipantSubscription%", Connection = "ServiceBusConnectionString_internal")]
     string messageBody,
     [DurableClient] DurableTaskClient durableClient,
     FunctionContext functionContext)
diff --git a/application/CohortManager/src/Functions/ExceptionHandling/CreateException/CreateException.cs b/application/CohortManager/src/Functions/ExceptionHandling/CreateException/CreateException.cs
@@ -53,7 +53,7 @@ public async Task<HttpResponseData> RunAsync([HttpTrigger(AuthorizationLevel.Ano
 
     [Function("RunCreateException")]
     public async Task Run(
-      [ServiceBusTrigger(topicName: "%CreateExceptionTopic%", subscriptionName: "%ExceptionSubscription%", Connection = "ServiceBusConnectionString_client_internal", AutoCompleteMessages = false)]
+            [ServiceBusTrigger(topicName: "%CreateExceptionTopic%", subscriptionName: "%ExceptionSubscription%", Connection = "ServiceBusConnectionString_internal", AutoCompleteMessages = false)]
         ServiceBusReceivedMessage message,
        ServiceBusMessageActions messageActions)
     {
diff --git a/application/CohortManager/src/Functions/ParticipantManagementServices/ManageParticipant/ManageParticipant.cs b/application/CohortManager/src/Functions/ParticipantManagementServices/ManageParticipant/ManageParticipant.cs
@@ -36,7 +36,7 @@ public ManageParticipant(ILogger<ManageParticipant> logger,
     /// </summary>
     /// <param name="message">json string containing the participant record</param>
     [Function(nameof(ManageParticipant))]
-    public async Task Run([ServiceBusTrigger(topicName: "%ParticipantManagementTopic%", subscriptionName: "%ManageParticipantSubscription%", Connection = "ServiceBusConnectionString_client_internal")] string message)
+    public async Task Run([ServiceBusTrigger(topicName: "%ParticipantManagementTopic%", subscriptionName: "%ManageParticipantSubscription%", Connection = "ServiceBusConnectionString_internal")] string message)
     {
         var participantRecord = JsonSerializer.Deserialize<BasicParticipantCsvRecord>(message)!;
         Participant participant = participantRecord.Participant;
diff --git a/application/CohortManager/src/Functions/ParticipantManagementServices/ManageServiceNowParticipant/ManageServiceNowParticipantFunction.cs b/application/CohortManager/src/Functions/ParticipantManagementServices/ManageServiceNowParticipant/ManageServiceNowParticipantFunction.cs
@@ -46,7 +46,7 @@ public ManageServiceNowParticipantFunction(ILogger<ManageServiceNowParticipantFu
     /// </summary>
     /// <param name="serviceNowParticipant">The participant from ServiceNow</param>
     [Function(nameof(ManageServiceNowParticipantFunction))]
-    public async Task Run([ServiceBusTrigger(topicName: "%ServiceNowParticipantManagementTopic%", subscriptionName: "%ManageServiceNowParticipantSubscription%", Connection = "ServiceBusConnectionString_client_internal")] ServiceNowParticipant serviceNowParticipant)
+    public async Task Run([ServiceBusTrigger(topicName: "%ServiceNowParticipantManagementTopic%", subscriptionName: "%ManageServiceNowParticipantSubscription%", Connection = "ServiceBusConnectionString_internal")] ServiceNowParticipant serviceNowParticipant)
     {
         try
         {

Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@ public AuditWriter(DataServicesContext dbContext, ILogger<AuditWriter> logger)`
`24`	`24`
`25`	`25`	`[Function(nameof(AuditWriter))]`
`26`	`26`	`public async Task Run(`
`27`		`- [ServiceBusTrigger(topicName: "%AuditTopicName%", subscriptionName: "%AuditSubscription%", Connection = "ServiceBusConnectionString_client_internal")] string messageText, FunctionContext context)`
	`27`	`+ [ServiceBusTrigger(topicName: "%AuditTopicName%", subscriptionName: "%AuditSubscription%", Connection = "ServiceBusConnectionString_internal")] string messageText, FunctionContext context)`
`28`	`28`	`{`
`29`	`29`	`ParticipantAuditMessage? audit;`
`30`	`30`	`try`
Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,7 @@ public async Task<HttpResponseData> RunAsync([HttpTrigger(AuthorizationLevel.Ano`
`53`	`53`
`54`	`54`	`[Function("RunCreateException")]`
`55`	`55`	`public async Task Run(`
`56`		`- [ServiceBusTrigger(topicName: "%CreateExceptionTopic%", subscriptionName: "%ExceptionSubscription%", Connection = "ServiceBusConnectionString_client_internal", AutoCompleteMessages = false)]`
	`56`	`+ [ServiceBusTrigger(topicName: "%CreateExceptionTopic%", subscriptionName: "%ExceptionSubscription%", Connection = "ServiceBusConnectionString_internal", AutoCompleteMessages = false)]`
`57`	`57`	`ServiceBusReceivedMessage message,`
`58`	`58`	`ServiceBusMessageActions messageActions)`
`59`	`59`	`{`
Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ public ManageParticipant(ILogger<ManageParticipant> logger,`
`36`	`36`	`/// </summary>`
`37`	`37`	`/// <param name="message">json string containing the participant record</param>`
`38`	`38`	`[Function(nameof(ManageParticipant))]`
`39`		`- public async Task Run([ServiceBusTrigger(topicName: "%ParticipantManagementTopic%", subscriptionName: "%ManageParticipantSubscription%", Connection = "ServiceBusConnectionString_client_internal")] string message)`
	`39`	`+ public async Task Run([ServiceBusTrigger(topicName: "%ParticipantManagementTopic%", subscriptionName: "%ManageParticipantSubscription%", Connection = "ServiceBusConnectionString_internal")] string message)`
`40`	`40`	`{`
`41`	`41`	`var participantRecord = JsonSerializer.Deserialize<BasicParticipantCsvRecord>(message)!;`
`42`	`42`	`Participant participant = participantRecord.Participant;`
Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ public ManageServiceNowParticipantFunction(ILogger<ManageServiceNowParticipantFu`
`46`	`46`	`/// </summary>`
`47`	`47`	`/// <param name="serviceNowParticipant">The participant from ServiceNow</param>`
`48`	`48`	`[Function(nameof(ManageServiceNowParticipantFunction))]`
`49`		`- public async Task Run([ServiceBusTrigger(topicName: "%ServiceNowParticipantManagementTopic%", subscriptionName: "%ManageServiceNowParticipantSubscription%", Connection = "ServiceBusConnectionString_client_internal")] ServiceNowParticipant serviceNowParticipant)`
	`49`	`+ public async Task Run([ServiceBusTrigger(topicName: "%ServiceNowParticipantManagementTopic%", subscriptionName: "%ManageServiceNowParticipantSubscription%", Connection = "ServiceBusConnectionString_internal")] ServiceNowParticipant serviceNowParticipant)`
`50`	`50`	`{`
`51`	`51`	`try`
`52`	`52`	`{`