1. class MessageQueue {
  2. constructor(name) {
  3. this.name = name;
  4. this.topics = {}; // topic: [message1, message2, ...]
  5. }
  7. subscribe(topic, callback) {
  8. if (!this.topics[topic]) {
  9. this.topics[topic] = [];
  10. }
  11. this.topics[topic].push(callback);
  12. }
  14. publish(topic, message) {
  15. if (this.topics[topic]) {
  16. this.topics[topic].forEach(callback => callback(message));
  17. }
  18. }
  19. }
  22. class DryRunMessageQueueInitializer {
  23. constructor() {
  24. this.queues = {};
  25. }
  27. createQueue(name) {
  28. this.queues[name] = new MessageQueue(name);
  29. }
  31. // Allows manual topic and message configuration for dry-run
  32. configureTopic(queueName, topic, messages) {
  33. if (!this.queues[queueName]) {
  34. console.warn(`Queue "${queueName}" does not exist.`);
  35. return;
  36. }
  37. this.queues[queueName].topics[topic] = messages;
  38. }
  40. //Allows manual subscription configuration
  41. configureSubscription(queueName, topic, callback) {
  42. if (!this.queues[queueName]) {
  43. console.warn(`Queue "${queueName}" does not exist.`);
  44. return;
  45. }
  46. this.queues[queueName].subscribe(topic, callback);
  47. }
  48. }
  52. //Example usage:
  53. // const initializer = new DryRunMessageQueueInitializer();
  54. // initializer.createQueue("myQueue");
  55. // initializer.configureTopic("myQueue", "topic1", ["message1", "message2"]);
  56. // initializer.configureSubscription("myQueue", "topic1", (message) => console.log(`Received: ${message}`));
  57. // initializer.publish("myQueue", "testMessage");

Add your comment