diff --git a/packages/stream/stream_client.js b/packages/stream/stream_client.js
index 577b2701dd..0f70866b75 100644
--- a/packages/stream/stream_client.js
+++ b/packages/stream/stream_client.js
@@ -327,16 +327,7 @@ _.extend(Meteor._Stream.prototype, {
         self._connected(data.data);
       else if (self.current_status.connected)
         _.each(self.event_callbacks.message, function (callback) {
-          try {
-            callback(data.data);
-          } catch (e) {
-            // XXX sockjs catches and silently ignores any exceptions
-            // that we raise here. not sure what we should do, but for
-            // now, just print the exception so you are at least aware
-            // that something went wrong.
-            // XXX improve error message
-            Meteor._debug("Exception while processing message", e.stack);
-          }
+          callback(data.data);
         });
 
       self._heartbeat_received();