upgrade amqper to 0.2.0

Author: taoyuan

lib/amqp/amqp-client.js

@@ -126,7 +126,7 @@ Client.prototype.for = function (params) {
 };
 
 function getResponseHandler(cache) {
-	return function (message) {
+	return function (err, message) {
 		var payload = message.payload;
 		if (!payload || !payload.id) return debug('invalid response', payload);
 

lib/amqp/amqp-server.js

@@ -34,7 +34,7 @@ function AMQPServer(server, amqpclient, options) {
 }
 
 function getRequestHandler(server, mqttserver) {
-	return function (message) {
+	return function (err, message) {
 		var payload = message.payload;
 		debug('received request', payload);
 		server.call(payload, function (error, success) {

package.json

@@ -24,7 +24,7 @@
     "mosca"
   ],
   "dependencies": {
-    "amqper": "^0.1.8",
+    "amqper": "^0.2.0",
     "debug": "^2.2.0",
     "expirable": "^0.1.0",
     "jayson": "^1.2.0",
@@ -37,6 +37,6 @@
   "devDependencies": {
     "chai": "*",
     "mocha": "*",
-    "mosca": "^0.31.0"
+    "mosca": "^0.31.1"
   }
 }