public function init(PushPipe $pushPipe, PushSettings $pushSettings)
    {
        $this->pushPipe = $pushPipe;
        $this->pushSettings = $pushSettings;

        if ($pushSettings->isPurgeOnStartup()) {
            $this->brokerModel->purgeQueue($pushSettings->getInputQueue());
        }
    }