code: def stringReceived(self, response):
          
          correlation_id = response[0:4]
          try:
              d = self._pending.pop(correlation_id)
          except KeyError:
              self._log.warn((
                  "Response has unknown correlation ID {correlation_id!r}."
                  " Dropping connection to {peer}."
              ), correlation_id=correlation_id, peer=self.transport.getPeer())
              self.transport.loseConnection()
          else:
              d.callback(response)
docs: Handle a response from the broker.