1. /**
  2. * Cleans up artifacts from message queues.
  3. *
  4. * @param {object} config Configuration object containing queue details.
  5. * @param {string} config.queueName The name of the queue to clean.
  6. * @param {string} config.connectionString The connection string for the message queue.
  7. * @param {string} config.cleanupStrategy The strategy to use for cleanup (e.g., 'deleteOldMessages', 'deleteDeadLetters').
  8. * @param {number} config.maxOldMessages The maximum number of old messages to delete (if applicable).
  9. */
  10. async function cleanupMessageQueue(config) {
  11. try {
  12. // Validate configuration
  13. if (!config || !config.queueName || !config.connectionString || !config.cleanupStrategy) {
  14. console.error("Invalid configuration provided.");
  15. return;
  16. }
  18. console.log(`Starting cleanup for queue: ${config.queueName}`);
  20. switch (config.cleanupStrategy) {
  21. case 'deleteOldMessages':
  22. await deleteOldMessages(config.queueName, config.connectionString, config.maxOldMessages);
  23. break;
  24. case 'deleteDeadLetters':
  25. await deleteDeadLetters(config.queueName, config.connectionString);
  26. break;
  27. default:
  28. console.warn(`Unknown cleanup strategy: ${config.cleanupStrategy}. Skipping cleanup.`);
  29. return;
  30. }
  32. console.log(`Cleanup completed for queue: ${config.queueName}`);
  34. } catch (error) {
  35. console.error(`Error during cleanup for queue ${config.queueName}:`, error);
  36. // Optionally, implement retry logic or alert a monitoring system here.
  37. }
  38. }
  40. /**
  41. * Deletes old messages from the queue.
  42. * @param {string} queueName The name of the queue.
  43. * @param {string} connectionString The connection string.
  44. * @param {number} maxOldMessages The maximum number of old messages to delete.
  45. */
  46. async function deleteOldMessages(queueName, connectionString, maxOldMessages) {
  47. // Placeholder for queue deletion logic. Replace with actual queue API calls.
  48. console.log(`Deleting old messages from queue ${queueName} with max ${maxOldMessages}`);
  49. // Simulate an asynchronous operation
  50. await new Promise(resolve => setTimeout(resolve, 500));
  51. console.log(`Finished deleting old messages from queue ${queueName}`);
  52. }
  54. /**
  55. * Deletes dead-letter messages from the queue.
  56. * @param {string} queueName The name of the queue.
  57. * @param {string} connectionString The connection string.
  58. */
  59. async function deleteDeadLetters(queueName, connectionString) {
  60. // Placeholder for dead-letter deletion logic. Replace with actual queue API calls.
  61. console.log(`Deleting dead-letter messages from queue ${queueName}`);
  62. // Simulate an asynchronous operation
  63. await new Promise(resolve => setTimeout(resolve, 500));
  64. console.log(`Finished deleting dead-letter messages from queue ${queueName}`);
  65. }
  67. // Example usage:
  68. // cleanupMessageQueue({
  69. // queueName: 'myQueue',
  70. // connectionString: 'your_connection_string',
  71. // cleanupStrategy: 'deleteOldMessages',
  72. // maxOldMessages: 100
  73. // });
  75. // cleanupMessageQueue({
  76. // queueName: 'myQueue',
  77. // connectionString: 'your_connection_string',
  78. // cleanupStrategy: 'deleteDeadLetters'
  79. // });

Add your comment