diff --git a/example-application/entry-points/message-queue-starter.js b/example-application/entry-points/message-queue-starter.js index e796cdb0..e8ed4be1 100644 --- a/example-application/entry-points/message-queue-starter.js +++ b/example-application/entry-points/message-queue-starter.js @@ -21,7 +21,7 @@ class MessageQueueStarter { const newMessageAsObject = JSON.parse(message); // ️️️✅ Best Practice: Validate incoming MQ messages using your validator framework (simplistic implementation below) if (!newMessageAsObject.id) { - return reject(new AppError('invalid-message', true)); + throw new AppError('invalid-message', true); } const orderRepository = new OrderRepository();