var Rascal = require('rascal');
var config = require('./config');
var redisCounter = require('rascal-redis-counter');
var counters = { redisCounter: redisCounter };
Rascal.Broker.create(Rascal.withDefaultConfig(config.rascal), { counters: counters }, function(err, broker) {
if (err) throw new err;
broker.on('error', function(err) {
console.error(err.message);
});
broker.subscribe(subscriptionName, function(err, subscription) {
if (err) throw new err;
subscription
.on('message', messageHander)
.on('invalid_content', function(err, message, ackOrNack) {
console.error('Invalid content', err.message);
ackOrNack(err, { strategy: 'nack' });
}).on('redeliveries_error', function(err, message, ackOrNack) {
console.error('Redeliveries Error', err);
ackOrNack(err, { strategy: 'nack' });
}).on('error', function(err) {
console.error(err.message);
});
});
});