Skip to content

Queue

In-memory and Redis message queue operations.

3 modules

ModuleDescription
Öğe Kuyruktan ÇıkarBir öğeyi kuyruktan çıkarın ve geri döndürün
Öğe Kuyruğa EkleBir öğeyi bellek içi veya Redis kuyruğuna ekleyin
Kuyruk BoyutuBir kuyruğun mevcut boyutunu alın

Modules

Öğe Kuyruktan Çıkar

queue.dequeue

Bir öğeyi kuyruktan çıkarın ve geri döndürün

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Öğeyi çıkaracağınız kuyruğun adı
backendstringNomemoryKullanılacak kuyruk arka planı
redis_urlstringNoredis://localhost:6379Redis bağlantı URL'si
timeoutnumberNo0Zaman aşımı süresi saniye cinsinden (0 = engellemesiz)

Output:

FieldTypeDescription
dataanyKuyruktan çıkarılan öğe (kuyruk boşsa null)
queue_namestringKuyruğun adı
remainingnumberKuyrukta kalan öğeler
emptybooleanKuyruğun boş olup olmadığı

Öğe Kuyruğa Ekle

queue.enqueue

Bir öğeyi bellek içi veya Redis kuyruğuna ekleyin

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Öğeyi ekleyeceğiniz kuyruğun adı
datastringYes-Kuyruğa eklenecek veri (herhangi bir JSON-serializable değer)
backendstringNomemoryKullanılacak kuyruk arka planı
redis_urlstringNoredis://localhost:6379Redis bağlantı URL'si

Output:

FieldTypeDescription
queue_namestringKuyruğun adı
positionnumberÖğenin kuyruktaki konumu
queue_sizenumberKuyruğa eklemeden sonra mevcut kuyruk boyutu

Kuyruk Boyutu

queue.size

Bir kuyruğun mevcut boyutunu alın

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Kontrol edilecek kuyruğun adı
backendstringNomemoryKullanılacak kuyruk arka planı
redis_urlstringNoredis://localhost:6379Redis bağlantı URL'si

Output:

FieldTypeDescription
queue_namestringKuyruğun adı
sizenumberKuyruktaki mevcut öğe sayısı

Released under the Apache 2.0 License.