public function run()
    {
        while (($payload = array_shift($this->payloads)) !== null) {
            list($ttr, $message) = $payload;
            $this->startedId = $this->finishedId + 1;
            $this->handleMessage($this->startedId, $message, $ttr, 1);
            $this->finishedId = $this->startedId;
            $this->startedId = 0;
        }
    }
public function run()
    {
        while (($payload = array_shift($this->payloads)) !== null) {
            list($ttr, $message) = $payload;
            $this->startedId = $this->finishedId + 1;
            $this->handleMessage($this->startedId, $message, $ttr, 1);
            $this->finishedId = $this->startedId;
            $this->startedId = 0;
        }
    }
public function run ( ) { while ( ( $ payload = array_shift ( $ this -> payloads ) ) !== null ) { list ( $ ttr , $ message ) = $ payload ; $ this -> startedId = $ this -> finishedId + 1 ; $ this -> handleMessage ( $ this -> startedId , $ message , $ ttr , 1 ) ; $ this -> finishedId = $ this -> startedId ; $ this -> startedId = 0 ; } }
Runs all jobs from queue.
Runs all jobs from queue .