UBERF-11712: Rework communication integration (#9335)

Signed-off-by: Andrey Sobolev <haiodo@gmail.com>
Signed-off-by: Kristina Fefelova <kristin.fefelova@gmail.com>
Co-authored-by: Kristina Fefelova <kristin.fefelova@gmail.com>

server/middleware/src/queue.ts

@@ -50,7 +50,10 @@ export class QueueMiddleware extends BaseMiddleware {
     }
     await Promise.all([
       this.provideBroadcast(ctx),
-      this.txProducer.send(this.context.workspace.uuid, ctx.contextData.broadcast.txes)
+      this.txProducer.send(
+        this.context.workspace.uuid,
+        ctx.contextData.broadcast.txes.concat(ctx.contextData.broadcast.queue)
+      )
     ])
   }
 }