1. class MessageQueueHandler {
  2. constructor(queueName, overrideStrategy = 'manual') {
  3. this.queueName = queueName;
  4. this.overrideStrategy = overrideStrategy;
  5. this.queue = new Map(); //Simulate message queue using Map
  6. }
  8. /**
  9. * Adds a message to the queue.
  10. * @param {any} message
  11. */
  12. addMessage(message) {
  13. this.queue.set(this.queueName, this.queue.get(this.queueName) || []);
  14. this.queue.get(this.queueName).push(message);
  16. //Simulate processing (delayed)
  17. setTimeout(() => {
  18. this.processQueue();
  19. }, 50); //Adjust delay as needed
  20. }
  22. /**
  23. * Processes messages from the queue.
  24. */
  25. processQueue() {
  26. if (!this.queue.has(this.queueName) || this.queue.get(this.queueName).length === 0) {
  27. return; // Queue is empty
  28. }
  30. const messages = this.queue.get(this.queueName);
  31. for (const message of messages) {
  32. try {
  33. this.handleMessage(message); //Attempt normal processing
  34. } catch (error) {
  35. if (this.overrideStrategy === 'manual') {
  36. this.manualOverride(message, error);
  37. } else {
  38. console.error("Unhandled error, skipping:", error);
  39. }
  40. }
  41. }
  42. this.queue.set(this.queueName, []); //Clear queue
  43. }
  45. /**
  46. * Handles a message. This is where your core message logic goes.
  47. * @param {any} message
  48. */
  49. handleMessage(message) {
  50. // Simulate processing - replace with your actual logic
  51. console.log(`Processing message: ${message}`);
  52. // Simulate a failure (for testing)
  53. if (Math.random() < 0.2) {
  54. throw new Error(`Simulated processing error for message: ${message}`);
  55. }
  56. console.log(`Finished processing message: ${message}`);
  57. }
  60. /**
  61. * Performs a manual override for a failed message.
  62. * @param {any} message
  63. * @param {Error} error
  64. */
  65. manualOverride(message, error) {
  66. console.warn(`Manual override triggered for message: ${message} due to error: ${error.message}`);
  67. //Implement your manual override logic here.
  68. //This might involve re-processing the message,
  69. //logging detailed information, or taking other corrective actions.
  70. console.log("Performing manual override...");
  71. //Example: Re-add the message to the queue for later processing
  72. this.addMessage(message);
  73. }
  75. /**
  76. * Gets the size of the queue.
  77. * @returns {number}
  78. */
  79. getQueueSize() {
  80. if(this.queue.has(this.queueName)){
  81. return this.queue.get(this.queueName).length;
  82. }
  83. return 0;
  84. }
  85. }
  87. // Example usage:
  88. const queueHandler = new MessageQueueHandler('myQueue', 'manual');
  90. queueHandler.addMessage('message1');
  91. queueHandler.addMessage('message2');
  92. queueHandler.addMessage('message3');
  94. // Simulate some time passing...
  95. setTimeout(() => {
  96. console.log("Queue size:", queueHandler.getQueueSize());
  97. }, 1000);

Add your comment