diff --git a/riak/transports/pbc/connection.py b/riak/transports/pbc/connection.py index b46f3014..a7093b15 100644 --- a/riak/transports/pbc/connection.py +++ b/riak/transports/pbc/connection.py @@ -62,7 +62,7 @@ def _non_connect_send_msg(self, msg_code, msg): Similar to self._send, but doesn't try to initiate a connection, thus preventing an infinite loop. """ - self._socket.send(self._encode_msg(msg_code, msg)) + self._socket.sendall(self._encode_msg(msg_code, msg)) def _send_msg(self, msg_code, msg): self._connect()