index.js 371 B

1234567891011
  1. const RabbitMQListener = require('./utils/RabbitMQListener');
  2. const { createLogger } = require('./utils/logger');
  3. const log = createLogger('linkedin');
  4. const rabbitMQListener = new RabbitMQListener();
  5. (async () => {
  6. await rabbitMQListener.listenToQueue('linkedin', (message) => {
  7. log.info({ action: 'message_received', outcome: 'success' }, message);
  8. });
  9. })();