public function subscribe(callable $handler)
    {
        $this->handlers[] = $handler;

        // laze subscribe
        if (!$this->subscribed) {
            $this->client->subscribe($this->queue_name, function ($message) {
                $this->handle($message);
            });
            $this->subscribed = true;
        }
    }