In questa pagina viene descritto il modulo di gestione delle code in itaEngine. Possiamo definire una coda come un'insieme di messaggi, che dovranno essere processati in ordine di inserimento (FIFO), al fine di rendere asincroni alcuni processi (Es. chiamate a web services).

Al file config.ini dovrà essere gestita la sesione [queue], che contiene le seguenti chiavi:

• queueType: Indica il tipo di implementazione utilizzata. Attualmente l'unico valore possibile è “cache”.
• cacheRoot: L'implementazione cache utilizzata è forzatamente “file”, in quanto “apc” vive solamente all'interno di un processo php che l'ha lanciata, quindi utilizzando la CLI per elaborare la coda, apc non sarà collegata ai dati di cache dell'applicativo, in quanto i processi sono differenti.

Il messaggio rappresenta il singolo elemento della coda. E' un'istanza della classe itaQueueMessage (presente in lib/itaPHPQueue/itaQueueMessage.class.php) ed ha le seguenti proprietà:

• uuid: UUID del messaggio (chiave assegnata dal sistema)
• alias: Alias che identifica univocamente il messaggio (assegnata dalla singola procedura)
• data: Dati del messaggio
• retries: Numero massimo di tentativi (in caso di errore durante esecuzione)
• executionMode: Modalità di esecuzione (immediata/differita)
• dateTimeDeferredExecution: Data e ora di esecuzione differita
• disabled: Messaggio disabilitato
• username: Nome utente utile per sapere chi ha inserito il messaggio in coda

Il gestore si occupa delle operazioni che andranno ad interagire con la coda. L'implementazione specifica è determinata dal parametro “queueType” presente nel file di configurazione (Utilizzando apposita factory). Attualmente l'unica implementazione possibile è quella fatta con la cache, la classe corrispondente è 'itaQueueManagerCache' (presente il lib/itaPHPQueue/ityaQueueManagerCache.class.php). Il gestore della coda si occupa delle seguenti operazioni:

• createQueue: Crea una nuova coda
• destroyQueue: Distrugge coda
• addMessage: Aggiunge un nuovo messaggio in coda
• getMessage: Preleva il primo messaggio (non disabilitato) dalla coda (con rimozione)
• queueExists: Verifica esistenza della coda
• queueStatus: Restituisce lo stato della coda
• getLastError: Restituisce l'ultimo errore avvenuto
• updateLastMessageProcessed: Effettua l'aggiornamento della coda con l'esecuzione del messaggio appena eseguito.

Per reperire l'oggetto gestore, occorre fare in questo modo:

itaQueueFactory::getQueueManager();