public function run($eventname, $count)
    {
        $queueEvents = $this->loadQueue($eventname, $count);

        if ($queueEvents->numRows) {
            while ($queueEvents->next()) {
                if ($this->checkInterval($queueEvents)) {
                    $this->setStartTime($queueEvents->id);
                    $jobEvent = $this->dispatch($queueEvents);
                    $this->setEndTime($queueEvents->id, $queueEvents->intervaltorun);
                    $this->saveJobResult($queueEvents->id, $jobEvent);
                }
            }
        } else {
            $this->response($eventname, 'noActiveJobs', 'INFO');
        }
    }
public function run($eventname, $count)
    {
        $queueEvents = $this->loadQueue($eventname, $count);

        if ($queueEvents->numRows) {
            while ($queueEvents->next()) {
                if ($this->checkInterval($queueEvents)) {
                    $this->setStartTime($queueEvents->id);
                    $jobEvent = $this->dispatch($queueEvents);
                    $this->setEndTime($queueEvents->id, $queueEvents->intervaltorun);
                    $this->saveJobResult($queueEvents->id, $jobEvent);
                }
            }
        } else {
            $this->response($eventname, 'noActiveJobs', 'INFO');
        }
    }
public function run ( $ eventname , $ count ) { $ queueEvents = $ this -> loadQueue ( $ eventname , $ count ) ; if ( $ queueEvents -> numRows ) { while ( $ queueEvents -> next ( ) ) { if ( $ this -> checkInterval ( $ queueEvents ) ) { $ this -> setStartTime ( $ queueEvents -> id ) ; $ jobEvent = $ this -> dispatch ( $ queueEvents ) ; $ this -> setEndTime ( $ queueEvents -> id , $ queueEvents -> intervaltorun ) ; $ this -> saveJobResult ( $ queueEvents -> id , $ jobEvent ) ; } } } else { $ this -> response ( $ eventname , 'noActiveJobs' , 'INFO' ) ; } }
Startet die Verarbeitung der Events eines Types der Queue.
@param $eventname
@param $count
Startet die Verarbeitung der Events eines Types der Queue .