Model/Importer.php
public function processQueue()
    {
        //Set items to 0
        $this->totalItems = 0;

        //Set bulk sync limit
        $this->bulkSyncLimit = 5;

        //Set priority
        $this->_setPriority();

        //Check previous import status
        $this->_checkImportStatus();

        //Bulk priority. Process group 1 first
        foreach ($this->bulkPriority as $bulk) {
            if ($this->totalItems < $bulk['limit']) {
                $collection = $this->_getQueue(
                    $bulk['type'],
                    $bulk['mode'],
                    $bulk['limit'] - $this->totalItems
                );
                if ($collection->getSize()) {
                    $this->totalItems += $collection->getSize();
                    $bulkModel = $this->objectManager->create($bulk['model']);
                    $bulkModel->sync($collection);
                }
            }
        }

        //reset total items to 0
        $this->totalItems = 0;

        //Single/Update priority.
        foreach ($this->singlePriority as $single) {
            if ($this->totalItems < $single['limit']) {
                $collection = $this->_getQueue(
                    $single['type'],
                    $single['mode'],
                    $single['limit'] - $this->totalItems
                );
                if ($collection->getSize()) {
                    $this->totalItems += $collection->getSize();
                    $singleModel = $this->objectManager->create(
                        $single['model']
                    );
                    $singleModel->sync($collection);
                }
            }
        }
    }
public function processQueue()
    {
        //Set items to 0
        $this->totalItems = 0;

        //Set bulk sync limit
        $this->bulkSyncLimit = 5;

        //Set priority
        $this->_setPriority();

        //Check previous import status
        $this->_checkImportStatus();

        //Bulk priority. Process group 1 first
        foreach ($this->bulkPriority as $bulk) {
            if ($this->totalItems < $bulk['limit']) {
                $collection = $this->_getQueue(
                    $bulk['type'],
                    $bulk['mode'],
                    $bulk['limit'] - $this->totalItems
                );
                if ($collection->getSize()) {
                    $this->totalItems += $collection->getSize();
                    $bulkModel = $this->objectManager->create($bulk['model']);
                    $bulkModel->sync($collection);
                }
            }
        }

        //reset total items to 0
        $this->totalItems = 0;

        //Single/Update priority.
        foreach ($this->singlePriority as $single) {
            if ($this->totalItems < $single['limit']) {
                $collection = $this->_getQueue(
                    $single['type'],
                    $single['mode'],
                    $single['limit'] - $this->totalItems
                );
                if ($collection->getSize()) {
                    $this->totalItems += $collection->getSize();
                    $singleModel = $this->objectManager->create(
                        $single['model']
                    );
                    $singleModel->sync($collection);
                }
            }
        }
    }
public function processQueue ( ) { //Set items to 0 $ this -> totalItems = 0 ; //Set bulk sync limit $ this -> bulkSyncLimit = 5 ; //Set priority $ this -> _setPriority ( ) ; //Check previous import status $ this -> _checkImportStatus ( ) ; //Bulk priority. Process group 1 first foreach ( $ this -> bulkPriority as $ bulk ) { if ( $ this -> totalItems < $ bulk [ 'limit' ] ) { $ collection = $ this -> _getQueue ( $ bulk [ 'type' ] , $ bulk [ 'mode' ] , $ bulk [ 'limit' ] - $ this -> totalItems ) ; if ( $ collection -> getSize ( ) ) { $ this -> totalItems += $ collection -> getSize ( ) ; $ bulkModel = $ this -> objectManager -> create ( $ bulk [ 'model' ] ) ; $ bulkModel -> sync ( $ collection ) ; } } } //reset total items to 0 $ this -> totalItems = 0 ; //Single/Update priority. foreach ( $ this -> singlePriority as $ single ) { if ( $ this -> totalItems < $ single [ 'limit' ] ) { $ collection = $ this -> _getQueue ( $ single [ 'type' ] , $ single [ 'mode' ] , $ single [ 'limit' ] - $ this -> totalItems ) ; if ( $ collection -> getSize ( ) ) { $ this -> totalItems += $ collection -> getSize ( ) ; $ singleModel = $ this -> objectManager -> create ( $ single [ 'model' ] ) ; $ singleModel -> sync ( $ collection ) ; } } } }
Proccess the data from queue.

@return null
Proccess the data from queue .