Wabbitzzz NPM | npm.io

wabbitzzz

Exchange

var Exchange = require('wabbitzzz').Exchange;
var exchanage = new Exchange({
		name: 'this_is_a_cool_exchange'
	});

exchange.publish({hi: 'you'});

// publish the message, but have rabbit hold it for 3 seconds first
exchange.delayedPublish({bye: 'you'}, {delay:3000});

Queue

var Queue = require('wabbitzzz').Queue;
var queue = new Queue({
		name: 'myQueue',
		exchangeNames:['this_is_a_cool_exchange'],
	});

queue(function(msg, ack){
	console.dir(msg);
	ack(); // pass something to ack for a failure
});

RPC Send

var rpc = require('wabbitzzz').request('method-name');
rpc(req, function(err, res){

});

RPC Listen

var rpc = require('wabbitzzz').response('method-name');
rpc(function(err, req, cb){

});

Policy

Do it like this.

Pattern	^(?!amq\.).*(?<!_rpc)$
Apply to	all
Definition	
ha-mode:	all
ha-sync-mode:	manual
Priority	-101

rabbitmq amqp

amqplib bluebird ezuuid lodash msgpackr

@everything-registry/sub-chunk-3108

9 months ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

1 year ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

2 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

4 years ago

4 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

6 years ago

6 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

7 years ago

8 years ago

8 years ago

8 years ago

8 years ago

8 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

9 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

10 years ago

11 years ago