diff --git a/src/Altinn.Broker.Integrations/Altinn/Events/AltinnEventBus.cs b/src/Altinn.Broker.Integrations/Altinn/Events/AltinnEventBus.cs index 42676095..e71e2d92 100644 --- a/src/Altinn.Broker.Integrations/Altinn/Events/AltinnEventBus.cs +++ b/src/Altinn.Broker.Integrations/Altinn/Events/AltinnEventBus.cs @@ -40,7 +40,7 @@ public async Task Publish(AltinnEventType type, string resourceId, string fileTr if (partyId != null) await _partyRepository.InitializeParty(organizationId, partyId); } } - var cloudEvent = CreateCloudEvent(type, resourceId, fileTransferId, partyId); + var cloudEvent = CreateCloudEvent(type, resourceId, fileTransferId, partyId, organizationId); var serializerOptions = new JsonSerializerOptions { PropertyNamingPolicy = new LowerCaseNamingPolicy() @@ -53,7 +53,7 @@ public async Task Publish(AltinnEventType type, string resourceId, string fileTr } } - private CloudEvent CreateCloudEvent(AltinnEventType type, string resourceId, string fileTransferId, string? partyId) + private CloudEvent CreateCloudEvent(AltinnEventType type, string resourceId, string fileTransferId, string? partyId, string? alternativeSubject) { CloudEvent cloudEvent = new CloudEvent() { @@ -64,7 +64,8 @@ private CloudEvent CreateCloudEvent(AltinnEventType type, string resourceId, str ResourceInstance = fileTransferId, Type = "no.altinn.broker." + type.ToString().ToLowerInvariant(), Source = _altinnOptions.PlatformGatewayUrl + "broker/api/v1/filetransfer", - Subject = !string.IsNullOrWhiteSpace(partyId) ? "/party/" + partyId : null + Subject = !string.IsNullOrWhiteSpace(partyId) ? "/party/" + partyId : null, + AlternativeSubject = !string.IsNullOrWhiteSpace(alternativeSubject) ? "/organisation/" + alternativeSubject : null, }; return cloudEvent;