protected function getPushType($queue_name)
    {
        if ($this->option('push_queue_type')) return $this->option('push_queue_type');

        try {
            return $this->getQueue($queue_name)->push_type;
        } catch (\Exception $e) {
            return 'multicast';
        }
    }