All files / worker index.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import { QueueHandler } from '../app/queue/queueHandler.js';
import { ClassName, RequestService, ServiceFactory } from '../app/service/serviceFactory.js';
import { QueueEnum } from '../app/types/QueueEnum.js';
import { Logger } from '../app/utils/logger.js';
import { Fibonacci } from './fibonacci.js';
import JobHandler from './jobHandler.js';

const RABBIT_URL = process.env.RABBIT_URL || 'amqp://localhost:5672';

const startConsume = async () => {
  const queueHandler = new QueueHandler(RABBIT_URL);
  const fibonacci = new Fibonacci();
  const requestService = await ServiceFactory.getInstanceOfClass<RequestService>(ClassName.RequestService);
  const jobHandler = new JobHandler(fibonacci, requestService);
  await queueHandler.attachJobHandlerToQueue(QueueEnum.Fibonacci, jobHandler);
};

startConsume()
  .then(() => {
    Logger.log('Started consuming:', QueueEnum.Fibonacci);
  })
  .catch((err) => {
    Logger.log('Error on starting consuming');
    Logger.error(err);
    // the worker has no consumer attached at this point and would otherwise sit
    // "Running" forever with an idle queue: exit non-zero so the restartPolicy
    // retries with backoff (rabbitmq is commonly not up yet on a fresh rollout)
    process.exit(1);
  });