resourceConnection = $resourceConnection; } /** * Removes subscriber from queue * * @param int $subscriberId * @return void */ public function execute(int $subscriberId): void { $connection = $this->resourceConnection->getConnection(); $connection->delete( $this->resourceConnection->getTableName('newsletter_queue_link'), ['subscriber_id = ?' => $subscriberId, 'letter_sent_at IS NULL'] ); } }