rabbitmq-decor is a RabbitMQ library presented as a set of class and method decorators for node services.

A number of message patterns are supported including:

• FnF (fire and forget), your method will simply respond to any message that appears on the argued queue.
• RPC (remote procedural call), your method will respond to any message on the queue, returning the method return to the replyTo queue.

Development

Add a file called .env at the project root so dotenv can provide environment variables to the testsuite.

rabbit_service:

decorate a class, allowing methods to join the message queue

args:
    options: Object - an options object
    options.URI: String - the URI of the rabbitmq service (eg. "amqp://user:pass@server:port"). default is the environment variable "RABBIT_URI"
    options.PERSISTENT_CONNECTION: Boolean - use a single shared connection for all queue endpoints (default true)

example of use
`
    @rabbit_service({URI: 'amqp://user:pass@place'})
    class MyClass {

    }
`

rpc:

rpc.listen:
    decorates a rabbit_service class method to the AMQP queue.

    args:
        queue: String - the name of the queue
        options: Object - see #queue options

    example of use:
    `
        @rabbit_service({URI: 'amqp://user:pass@place'})
        class MyClass {

            @rpc.listen(`hello_world`)
            async helloWord( msg ) {
                return 'hello there';
            }

        }
    `

rpc.serve:
    @todo

rpc.invoke:
    @todo

rpc.close:

fnf:

fnf.listen:
    decorates a rabbit_service class method to the AMQP queue

rpc.serve:
    @todo

rpc.invoke:
    @todo

rpc.close:
    @todo

Environment Variables:

RABBIT_URI: the server location - example: amqp://user:pass@server:port
LOGFILE: the absolute file location for a logfile (default:none, logging will occur on std out)
TIMEFORMAT: A timeformat for log output : example YYYY-MM-DD HH:mm:ss.SSS