Skip to content

Queue

In-memory and Redis message queue operations.

3 modules

ModuleDescription
Rimuovi elementoRimuovi e restituisci un elemento da una coda
Accoda elementoAggiungi un elemento a una coda in memoria o Redis
Dimensione codaOttieni la dimensione attuale di una coda

Modules

Rimuovi elemento

queue.dequeue

Rimuovi e restituisci un elemento da una coda

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Nome della coda da cui rimuovere
backendstringNomemoryBackend della coda da utilizzare
redis_urlstringNoredis://localhost:6379URL di connessione Redis
timeoutnumberNo0Timeout in secondi (0 = non bloccante)

Output:

FieldTypeDescription
dataanyL'elemento rimosso (null se la coda è vuota)
queue_namestringNome della coda
remainingnumberElementi rimanenti nella coda
emptybooleanSe la coda era vuota

Accoda elemento

queue.enqueue

Aggiungi un elemento a una coda in memoria o Redis

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Nome della coda a cui aggiungere l'elemento
datastringYes-Dati da accodare (qualsiasi valore serializzabile in JSON)
backendstringNomemoryBackend della coda da utilizzare
redis_urlstringNoredis://localhost:6379URL di connessione Redis

Output:

FieldTypeDescription
queue_namestringNome della coda
positionnumberPosizione dell'elemento nella coda
queue_sizenumberDimensione attuale della coda dopo l'accodamento

Dimensione coda

queue.size

Ottieni la dimensione attuale di una coda

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Nome della coda da controllare
backendstringNomemoryBackend della coda da utilizzare
redis_urlstringNoredis://localhost:6379URL di connessione Redis

Output:

FieldTypeDescription
queue_namestringNome della coda
sizenumberNumero attuale di elementi nella coda

Released under the Apache 2.0 License.