antirez / antirez/disque

Queue tagging

Abierto
#130 3 comentarios 0 reacciones 0 asignados Ver en GitHub
Lenguaje dominante
C
Estrellas
8.1k
Forks
532
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

Hey guys

I'm looking to move from SoftLayers message queue to Disque in the future once a stable release is out.
However one of the features that I've found incredibly useful from SL's messaging queue is the ability to tag queues.

For example we have several workflows for when a new user registers (e.g. welcome email, schedule on-boarding drip feed etc). Instead of having to persist somewhere the name of each queue and its role we can simply collect up all the queues with the tag `user_register` and submit the same message to each.

``` php
$queues = $messaging->queues(array('user_register'));
foreach ($queues as $q)
{
$q->message()
->addField('userId', $user->getId())
->create();
}
```

This means if we add a new worker that wants to ingest messages relating to that tag (e.g. a feedback email) we just need to add that tag to the queue and then they will receive those messages.

As I understand this would require making queues somewhat persistent as currently they only exist while they contain messages.

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.