diff --git a/lib/ddp-client.js b/lib/ddp-client.js
index 6ab02cc..0031aa5 100644
--- a/lib/ddp-client.js
+++ b/lib/ddp-client.js
@@ -152,6 +152,14 @@ DDPClient.prototype._message = function(data) {
     self.session = data.session;
     self.emit("connected");
 
+  // method error
+  } else if (data.msg === "error") {
+    var cb = self._callbacks[data.offendingMessage.id];
+    if (cb) {
+        cb(data.reason, data.offendingMessage);
+        delete self._callbacks[data.offendingMessage.id];
+    }
+
   // method result
   } else if (data.msg === "result") {
     var cb = self._callbacks[data.id];