larvitamintercom

Larvitamintercom

Communication wrapper for rabbitmq in autobahn.

Usage

Send

send() to autobahn.

const	Intercom	= require('larvitamintercom'),
	conStr	= 'amqp://user:password@192.168.0.1/',
	intercom	= new Intercom(conStr);

let	message	= {'hello':	'world'},
	options	= {'exchange':	'foo'}; // Will default to "default" if options is omitted

intercom.send(message, options, function(err) {
	// called when message is accepted by queue handler
}, function(err) {
	// called when all consumeres have acked the message
});

Default send options:

{
	'exchange':	'default',
	'durable':	true
}

Read

There are two types of read operations; "consume" and "subscribe".

A message can only be "consumed" once, but it can be "subscribed" several times, by different readers.

Consumers can be assigned to an exchanged after the message have been sent, and they still receive the message.

Subscribers, in contrast, must subscribe BEFORE the message is sent or they will not receive it.

Each subscriber only get each message once.

Consume

const	Intercom	= require('larvitamintercom'),
	conStr	= 'amqp://user:password@192.168.0.1/',
	intercom	= new Intercom(conStr);

let options = {'exchange': 'foo'}; // Will default to "default" if options is omitted

intercom.consume(options, function(message, ack) {
	// message being the object sent with intercom.send()

	// Must be ran! Always! ACK!!
	ack();
	// or
	ack(new Error('Something was wrong with the message'));
}, function(err) {
	// Callback from established consume connection
});

Default consume options:

{
	'exchange':	'default'
}

Subscribe

const	Intercom	= require('larvitamintercom').Intercom,
	conStr	= 'amqp://user:password@192.168.0.1/',
	intercom	= new Intercom(conStr);

let options = {'exchange': 'default'};

intercom.subscribe(options, function(message, ack) {
	// message subscribe the object sent with intercom.send()

	// Must be ran! Always! ACK!!
	ack();
	// or
	ack(new Error('Something was wrong with the message'));
}, function(err) {
	// Callback from established subscribe connection
});

Default subscribe options:

{
	'exchange':	'default'
}