1. /**
  2. * Reloads message queue configuration with retry logic.
  3. * @param {function} reloadConfig - Function to reload the configuration. Should return a promise.
  4. * @param {number} maxRetries - Maximum number of retry attempts.
  5. * @param {number} delayMs - Delay between retries in milliseconds.
  6. * @returns {Promise<void>} - A promise that resolves when the configuration is successfully reloaded or rejects after maxRetries attempts.
  7. */
  8. async function reloadMessageQueueConfig(reloadConfig, maxRetries = 3, delayMs = 1000) {
  9. let retries = 0;
  11. while (retries < maxRetries) {
  12. try {
  13. // Attempt to reload the configuration.
  14. await reloadConfig();
  15. console.log("Message queue configuration reloaded successfully.");
  16. return; // Exit the function if successful.
  17. } catch (error) {
  18. console.error(`Failed to reload message queue configuration. Retry attempt ${retries + 1}/${maxRetries}:`, error);
  19. retries++;
  21. if (retries < maxRetries) {
  22. // Wait before retrying.
  23. await new Promise(resolve => setTimeout(resolve, delayMs));
  24. } else {
  25. // Reached the maximum number of retries.
  26. console.error("Failed to reload message queue configuration after multiple retries.");
  27. throw error; // Re-throw the error to signal failure.
  28. }
  29. }
  30. }
  31. }
  34. // Example usage (replace with your actual reloadConfig function)
  35. // async function myReloadConfig() {
  36. // // Replace with your logic to reload the message queue configuration
  37. // console.log("Reloading config...");
  38. // await new Promise(resolve => setTimeout(resolve, 500)); // Simulate a delay
  39. // console.log("Config reloaded.");
  40. // }
  42. // reloadMessageQueueConfig(myReloadConfig, 5, 2000)
  43. // .then(() => console.log("Configuration reload process completed."))
  44. // .catch(err => console.error("Configuration reload failed after all retries:", err));

Add your comment