diff --git a/adminforth/dataConnectors/baseConnector.ts b/adminforth/dataConnectors/baseConnector.ts
index 8128aadce..d95b05a4c 100644
--- a/adminforth/dataConnectors/baseConnector.ts
+++ b/adminforth/dataConnectors/baseConnector.ts
@@ -25,18 +25,21 @@ type AdminForthFilterNormalizationResult = {
 };
 
 async function publishShowPageUpdate(resource: AdminForthResource, recordId: string, updates: Record<string, any>) {
-  await global.adminforth.websocket.publish(`/showPage/${resource.resourceId}/${String(recordId)}`, 
-    {
+  await global.adminforth.websocket.publish({
+    topic: `/showPage/${resource.resourceId}/${String(recordId)}`,
+    data: {
       resourceId: resource.resourceId,
       recordId,
       updates,
     },
-    async (adminUser: AdminUser): Promise<boolean> => {
+    filterUsers: async (adminUser: AdminUser): Promise<boolean> => {
+      console.log(`Checking show access for ${resource.resourceId} record ${recordId} `);
       if (!adminUser) {
         // anonymous clients should never receive record updates
         return false;
       }
       try {
+        console.log(`Checking show access for ${resource.resourceId} record ${recordId}`);
         const { allowedActions } = await interpretResource(
           adminUser,
           resource,
@@ -44,12 +47,14 @@ async function publishShowPageUpdate(resource: AdminForthResource, recordId: str
           ActionCheckSource.ShowRequest,
           global.adminforth,
         );
+        console.log(`Allowed actions for ${resource.resourceId} record ${recordId} for user: ${JSON.stringify(allowedActions)}`);
         return allowedActions[AllowedActionsEnum.show] === true;
       } catch (e) {
         afLogger.error(`Error while checking show access for ${resource.resourceId} record ${recordId}, assuming update should not be sent: ${e}`);
         return false;
       }
     }
+  }
   );
 }
 
diff --git a/adminforth/modules/socketBroker.ts b/adminforth/modules/socketBroker.ts
index 5b59786e7..23fb194af 100644
--- a/adminforth/modules/socketBroker.ts
+++ b/adminforth/modules/socketBroker.ts
@@ -154,13 +154,19 @@ export default class SocketBroker implements IWebSocketBroker {
   }
 
   async publish(topic: string, data: any, filterUsers?: (adminUser: AdminUser) => Promise<boolean>): Promise<void> {
+    console.log(`_____________________________________________Publishing to topic ${topic} data ${JSON.stringify(data)}`);
+    console.log("Does filterUsers exist? ", filterUsers ? "Yes" : "No");
     if (!this.topics[topic]) {
+      console.log(`No clients subscribed to topic ${topic}`);
       afLogger.trace(`No clients subscribed to topic ${topic}`);
       return;
     }
     for (const client of this.topics[topic]) {
+      console.log(`Sending data to socket ${topic} ${JSON.stringify(data)}`);
       if (filterUsers) {
+        console.log(`Filtering users for topic ${topic} ${client.adminUser}`);
         if (! (await filterUsers(client.adminUser)) ) {
+          console.log(`Client not authorized to receive message ${topic} ${client.adminUser}`);
           afLogger.trace(`Client not authorized to receive message ${topic} ${client.adminUser}`);
           continue;
         }