public function get($queue, $noAck = false): Observable
    {
        $promise = $this->channel->get($queue, $noAck);

        return Observable::fromPromise($promise)
            ->map(function (BaseMessage $message) {
                return new Message($this->channel, $message);
            });
    }