oliveiragahenrique

oliveiragahenrique

I’m building a system which must have a queue and a kind of consumer, that will consume the events of the queue and remove them only if succeeds.

I’m thinking about model the queue and the consumer as different gen servers:

Queue process: Handle insert, get first event and delete operations
Consumer process: Handle consume operation (series of steps over the event data, which may fail)

Both processes have a 1:1 relationship, which means a specific queue has only one consumer and the consumer only consumes from one queue.

The consumer will call it self periodically, requesting to consume an event! This processes consist in a series of calls to the queue process, ultimately removing the event from the queue.

I’m currently thinking about some decisions:

1 - Would be useful to separate the registration of both process under two different Registry?
2 - Since consumer do not make sense without a queue, and the consumer can crash more easily, I was thinking if the Queue process could supervise the consumer process, thoughts on this?

How would you guys solve it, have some repository which implements something similar?

Showing Posts 1 to 1

kokolegorille

kokolegorille

Producer, Consumer… => GenStage

And other related tools, like Flow and Broadway. in case of error, it could be pushed into an error queue.

It’s nice to build something like this, but GenStage allow creation of pipeline of Producer, Consumer/Producer, Consumer with back pressure support.

— All posts loaded —

Where Next? Top

Trending in Discussions Top

AstonJ
As the title says, please share what you’ve been up to with Elixir. Whether that’s been learning it, looking into it, making stuff with i...
2977 92995 915
New
caslu
I want to open this thread for you all to discuss and help those who really like Ash but are still hesitant to use it in a real project. ...
New
mudasobwa
I am happy to introduce the very α version of the new programming language compiled to BEAM. Welcome Cure. It has literally three kille...
New
GES233
I’m posting this in response to Jose’s recent tweet (Cr. link) : People are sleeping on Elixir for a coding harness: Hot-code swappi...
New
_mfierro
Hello, I wrote Stop My Hand, a Scattergories-like web application using Phoenix/LiveView as my learning project for Elixir (after readin...
New
marciol
It would be helpful to have a list of companies worldwide that hire engineers without prior experience in Elixir. Often, it can be quite ...
New
durvia
Anyone running long-lived stateful processes on BEAM? We’re building an AI agent runtime and would love to compare notes. We’re a small ...
New

Other Trending Topics Top

garrison
Hobbes is a low-level distributed database for the Elixir programming language. Hobbes provides a simple, safe, and scalable storage lay...
New
marciok
Hi there! We created Gust: A task orchestrator inspired by Airflow. For those who have never heard about Aiflow, it’s a Python-based wor...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
Damirados
Hello everyone. After busy few months I am happy to announce v0.1.0 of Emerge & Solve. They are GUI (Emerge) and State management (S...
New
netoum
Corex is an accessible, unstyled UI component library for Phoenix that integrates Zag.js state machines using Vanilla JavaScript and Live...
New
wintermeyer
There are three potential reasons for members of this forum to have a look at https://vutuv.de You are tired or annoyed of LinkedIn. Yo...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews