public function get($queue, $noAck = false)
    {
        $promise = $this->channel->get($queue, $noAck);
        return \Rxnet\fromPromise($promise)
            ->map(function (Message $message) {
                return new RabbitMessage($this->channel, $message, $this->serializer);
            });
    }