servicesamqp v0.2.3

Get Started

const options = {
  url: 'amqp://rabbitmq:rabbitmq@localhost:5672', // RabbitMQ connection string,
  listeners: {
    'simple-message-queue': {
      controller: ({ json }) => { /* your code */ }
    },

    'simple-message-queue-async': {
      controller: async ({ json }) => { /* your async code */ }
    },

    'rpc-messages': {
      rpc: true,
      controller: async () => { /* your async code */ }
    },
  },

  commands: {
    pushSimpleMessage: {
      queue: 'simple-message-queue',
    },
    
    pushRpcMessage: {
      rpc: true,
      queue: 'rpc-messages',
    },
  },
};

const servicesAMQP = new ServicesAMQP(options);

servicesAMQP.setup() // return Promise

// example simple message
await servicesAMQP.cmd.pushSimpleMessage({ hello: 'world' })

// example rpc call
const response = await servicesAMQP.cmd.pushRpcMessage({ hello: 'world' })

Options