public function receive(QueueClientInterface $queue, $maxMessages = 1, ReceiveParametersInterface $params = null)
    {
        $messages = $queue->receive($maxMessages, $params);
        $lastResult = [];

        foreach ($messages as $message) {
            if ($message instanceof MessageInterface) {

                $lastResult = $this->process($message);

                if ($queue->canDeleteMessage()) {
                    $queue->delete($message);
                }
            }
            // TODO: else?
        }

        return $lastResult;
    }