sviluppo:queue
Differenze
Queste sono le differenze tra la revisione selezionata e la versione attuale della pagina.
Entrambe le parti precedenti la revisioneRevisione precedenteProssima revisione | Revisione precedente | ||
sviluppo:queue [2017/04/13 08:03] – m.biagioli | sviluppo:queue [2024/10/15 09:45] (versione attuale) – modifica esterna 127.0.0.1 | ||
---|---|---|---|
Linea 23: | Linea 23: | ||
=====Coda===== | =====Coda===== | ||
+ | La coda è composta dalle seguenti informazioni: | ||
+ | * **id**: Identificativo coda (fisso in base alla tipologia, es. ANPR) | ||
+ | * **status**: Contiene lo stato della coda | ||
+ | * **messages**: | ||
+ | Lo stato, a sua volta, contiene le seguenti informazioni: | ||
+ | * **lastMessageInserted**: | ||
+ | * **lastMessageProcessed**: | ||
+ | * **lastQueueModifyTime**: | ||
+ | * **messagesToProcess**: | ||
+ | * **customAttributes**: | ||
=====Gestore della Coda===== | =====Gestore della Coda===== | ||
Linea 38: | Linea 47: | ||
* **getLastError**: | * **getLastError**: | ||
* **updateLastMessageProcessed**: | * **updateLastMessageProcessed**: | ||
+ | * **findMessage**: | ||
+ | * **updateMessage**: | ||
Per reperire l' | Per reperire l' | ||
< | < | ||
- | itaQueueFactory:: | + | $qm = itaQueueFactory:: |
</ | </ | ||
+ | Esempio di creazione di una coda: | ||
+ | < | ||
+ | $created = $qm-> | ||
+ | </ | ||
+ | |||
+ | =====Worker===== | ||
+ | Ogni tipologia di coda ha una classe worker specifica, che si occupa dell' | ||
+ | Ad esempio, per ANPR, la classe specifica è ' | ||
+ | Il worker è chiamato dal CLI, anch' | ||
+ | |||
+ | |||
+ | =====Daemon===== | ||
+ | Per fare in modo che la coda giri come servizio, è opportuno scrivere un apposito daemon e registrarlo nel sistema come servizio. | ||
+ | Per creare un nuovo daemon, basta semplicemente creare una nuova classe in / | ||
+ | |||
+ | < | ||
+ | < | ||
+ | </ | ||
+ | |||
+ | I metodi da implementare sono: | ||
+ | * **executeStart**: | ||
+ | * **executeStop**: | ||
+ | * **getSleepTime**: | ||
+ | |||
+ | Per maggiori informazioni consultare la documentazione relativa ad [[itaDaemon|itaDaemon]]{{counter}} visualizzazioni. | ||
sviluppo/queue.1492070633.txt.gz · Ultima modifica: 2018/03/19 10:45 (modifica esterna)