def data_received(self, data): message = msgpack.unpackb(data, encoding='utf-8') self.orchestrator.data_received_client(self, message)