servicebus
Advanced tools
Comparing version 1.0.18 to 1.0.19
@@ -12,6 +12,12 @@ function packageMessage (queueName, message, next) { | ||
function handleIncoming (channel, message, options, next) { | ||
message.content.type = message.properties.type || message.content.type; | ||
next(null, channel, message, options); | ||
} | ||
module.exports = function () { | ||
return { | ||
handleOutgoing: packageMessage | ||
handleOutgoing: packageMessage, | ||
handleIncoming: handleIncoming | ||
}; | ||
} | ||
}; |
@@ -10,3 +10,3 @@ { | ||
"description": "Simple service bus for sending events between processes using amqp.", | ||
"version": "1.0.18", | ||
"version": "1.0.19", | ||
"homepage": "https://github.com/mateodelnorte/servicebus", | ||
@@ -13,0 +13,0 @@ "repository": { |
59045
1432