Method send_msg

cassandra/connection.py:1071–1091

(self, msg, request_id, cb, encoder=ProtocolHandler.encode_message, decoder=ProtocolHandler.decode_message, result_metadata=None)

                log.exception("Pushed event handler errored, ignoring:")

    def send_msg(self, msg, request_id, cb, encoder=ProtocolHandler.encode_message, decoder=ProtocolHandler.decode_message, result_metadata=None):
        if self.is_defunct:
            raise ConnectionShutdown("Connection to %s is defunct" % self.endpoint)
        elif self.is_closed:
            raise ConnectionShutdown("Connection to %s is closed" % self.endpoint)
        elif not self._socket_writable:
            raise ConnectionBusy("Connection %s is overloaded" % self.endpoint)

        # queue the decoder function with the request
        # this allows us to inject custom functions per request to encode, decode messages
        self._requests[request_id] = (cb, decoder, result_metadata)
        msg = encoder(msg, request_id, self.protocol_version, compressor=self.compressor,
                      allow_beta_protocol_version=self.allow_beta_protocol_version)

        if self._is_checksumming_enabled:
            buffer = io.BytesIO()
            self._segment_codec.encode(buffer, msg)
            msg = buffer.getvalue()

        self.push(msg)
        return len(msg)

    def wait_for_response(self, msg, timeout=None, **kwargs):
        return self.wait_for_responses(msg, timeout=timeout, **kwargs)[0]