diff --git a/pymongo/pool.py b/pymongo/pool.py
index 74965620e..b04e4bd33 100644
--- a/pymongo/pool.py
+++ b/pymongo/pool.py
@@ -606,7 +606,7 @@ class SocketInfo(object):
         self.more_to_come = reply.more_to_come
         unpacked_docs = reply.unpack_response()
         response_doc = unpacked_docs[0]
-        helpers._check_command_response(response_doc)
+        helpers._check_command_response(response_doc, self.max_wire_version)
         return response_doc
 
     def command(self, dbname, spec, slave_ok=False,
diff --git a/test/test_discovery_and_monitoring.py b/test/test_discovery_and_monitoring.py
index 27f385d6a..ef97bcc67 100644
--- a/test/test_discovery_and_monitoring.py
+++ b/test/test_discovery_and_monitoring.py
@@ -334,7 +334,8 @@ class TestIntegration(SpecRunner):
 
         Assert the given event was published exactly `count` times.
         """
-        self.assertEqual(self._event_count(event), count)
+        self.assertEqual(self._event_count(event), count,
+                         'expected %s not %r' % (count, event))
 
     def wait_for_event(self, event, count):
         """Run the waitForEvent test operation.