vsimol som si, ze objekt, ktory ma spracuvat message sa vytvoi az ked pride prvy message na spracovanie. co je teda fajn a vobec mi to nevadi, ale chcel by som publikovat dalsie message cez zeromq pub socket.

vytvaram ho v contructore procesora, ale pripojenie socketu je asynchronne, takze mi 1. message zmq uplne odignoruje. ak uz bezi consumer trochu dlhsie, vsetky message prechadzaju.

nedalo by sa pridat nastavenie, aby sa tieto processory vytvarali hned pri zapnuti consumera?

Asi moc nechápu co řešíš, protože samotný processor se inicializuje hned po vytvoření consumera a consumer se v commandu vytváří už v initializace toho commandu.

/**
 * @return Kdyby\RabbitMq\Consumer
 */
public function createServiceRabbitmq__consumer__logistics()
{
    $service = new Kdyby\RabbitMq\Consumer($this->getService('rabbitmq.default.connection'));
    $service->setCallback(array(
        $this->getService('384_Logistics_CargoQueue'),
        'process',
    ));

Tedy v momentě kdy pustíš consumera přes cli, tak by se měl vytvořit i processor.


You must first log in to participate in this discussion