diff --git a/lib/fudd.js b/lib/fudd.js index d5a0e0b..7a8b360 100644 --- a/lib/fudd.js +++ b/lib/fudd.js @@ -38,7 +38,7 @@ var Fudd = { var establishChannel = [Fudd._connect.bind(null, config), Fudd._createChannel]; series(establishChannel, function(error, connection, channel) { - if(error) return finalCallback(error); + if (error) return finalCallback(error); var infrastructure = []; config.exchanges.reduce(function(series, exchangeDefinition) { @@ -80,10 +80,10 @@ var Fudd = { } }, _deleteExchange: function(channel, exchangeDefinition, callback) { - channel.deleteExchange(exchangeDefinition.name, {}, function(error) { callback(error)}); + channel.deleteExchange(exchangeDefinition.name, {}, function(error) { callback(error);}); }, _deleteQueue: function(channel, queueDefinition, callback) { - channel.deleteQueue(queueDefinition.name, {}, function(error) { callback(error)}); + channel.deleteQueue(queueDefinition.name, {}, function(error) { callback(error);}); }, _connect: function(config, callback) { var url = formatAmqpUrl(config.cluster);