code: def receive_message(self):
  		
  		while not self.recv_message_queue:
  			self.transport.fill_inbuffer()
  		message = self.recv_message_queue.pop(0)
  		assert message is not None
  		if not message.verify(self.protocol.authenticators):
  			self.close()
  			raise OmapiError("bad omapi message signature")
  		return message
docs: Read the next message from the connection.
  		@rtype: OmapiMessage
  		@raises OmapiError:
  		@raises socket.error: