public function listen($channel, $expr, callable $handler)
    {
        $this->adapter->subscribe($channel, function ($message) use ($expr, $handler) {
            $this->handleSubscribeCallback($message, $expr, $handler);
        });
    }