service_amqp_messaging v1.0.0

Description

This is a simple library, which helps to initialize connection between microservices by amqp protocol.

How to initialize

Prepare callback function. Example:

  const handleMessage = async (message: IMessage) => {
    switch (message.code) {
      case (MessageCodes.DO_SMTG): {
        const result = await service.doSmtg(message.body);
        return result;
      }
    }
  }

Call configureService function. First parameter is a Service name, second is a callback function. Example:

  await configureService('serviceName', handleMessage);

How to use

If you want to call function from another service, you should use sendRequest method. It would search required function in specified service from handleMessage function by message code.

Example:

  const result = await sendRequest(MessageCodes.DO_SMTG, data, 'serviceName');

In case of service unavailable (in case of service restart or etc) requests would be stored in queue and executes when service would be available.