diff --git a/apps/worker/src/whatsapp/session-pool.ts b/apps/worker/src/whatsapp/session-pool.ts
index 73c4fcf..d69a804 100644
--- a/apps/worker/src/whatsapp/session-pool.ts
+++ b/apps/worker/src/whatsapp/session-pool.ts
@@ -1,4 +1,5 @@
-import { WASocket } from '@whiskeysockets/baileys';
+import { WASocket, DisconnectReason } from '@whiskeysockets/baileys';
+import { Boom } from '@hapi/boom';
 import { NormalizedMessage, NormalizedReaction } from '@tower/types';
 import { createWhatsAppSession } from './session';
 import { createLogger } from '@tower/logger';
@@ -66,7 +67,7 @@ export class WhatsAppSessionPool {
     logger.info({ count: this.sessions.size }, 'Closing all WhatsApp sessions');
     for (const [accountId, sock] of this.sessions) {
       try {
-        sock.end(undefined);
+        sock.end(new Boom('Shutdown', { statusCode: DisconnectReason.loggedOut }));
         logger.info({ accountId }, 'Session closed');
       } catch (err) {
         logger.error({ accountId, err }, 'Error closing session');