diff --git a/apps/backend/src/datasources/stfc/StfcUserDataSource.ts b/apps/backend/src/datasources/stfc/StfcUserDataSource.ts
index 82031914b1..300185b29a 100644
--- a/apps/backend/src/datasources/stfc/StfcUserDataSource.ts
+++ b/apps/backend/src/datasources/stfc/StfcUserDataSource.ts
@@ -779,6 +779,8 @@ export class StfcUserDataSource implements UserDataSource {
   async getApprovedProposalVisitorsWithInstitution(
     proposalPk: number
   ): Promise<{ user: User; institution: Institution; country: Country }[]> {
-    throw new Error('Method not implemented.');
+    return await postgresUserDataSource.getApprovedProposalVisitorsWithInstitution(
+      proposalPk
+    );
   }
 }
diff --git a/apps/backend/src/eventHandlers/messageBroker.ts b/apps/backend/src/eventHandlers/messageBroker.ts
index 0db6464179..22d2456d7a 100644
--- a/apps/backend/src/eventHandlers/messageBroker.ts
+++ b/apps/backend/src/eventHandlers/messageBroker.ts
@@ -130,7 +130,6 @@ export const getProposalMessageData = async (proposal: Proposal) => {
 
   const proposalUsersWithInstitution =
     await userDataSource.getProposalUsersWithInstitution(proposal.primaryKey);
-
   const dataAccessUsersWithInstitution =
     await dataAccessUsersDataSource.getDataAccessUsersWithInstitution(
       proposal.primaryKey
@@ -402,6 +401,19 @@ export async function createPostToRabbitMQHandler() {
 
         const proposal = await proposalDataSource.get(proposalPKey);
 
+        const jsonMessage = await getProposalMessageData(proposal!);
+        await rabbitMQ.sendMessageToExchange(
+          EXCHANGE_NAME,
+          Event.PROPOSAL_UPDATED,
+          jsonMessage
+        );
+        break;
+      }
+      case Event.DATA_ACCESS_USERS_UPDATED: {
+        const { proposalPKey } = event;
+
+        const proposal = await proposalDataSource.get(proposalPKey);
+
         const jsonMessage = await getProposalMessageData(proposal!);
         await rabbitMQ.sendMessageToExchange(
           EXCHANGE_NAME,