Comments (4)
Hi,
sorry for that! I just added the elixir*.ez
file to the release and updated the README. Thanks for reporting!
The plugin relies on mnesia
to cache the already seen messages. The table should be shared across nodes of the same cluster. If one node crashes, it will copy the table over once it restarts. I have not tested the scenario yet though (it's version 0.0.1 ;) ).
The tables are stored in memory for simplicity and performance reason. If you need a more robust mechanism what I could do is adding a configuration flag to force the cache on disk. I am not sure about how the consistency would be ensured across multiple nodes though. Some investigation would be required.
This plugin aims to be a simple yet effective way to reduce the amount of duplicate messages published to the queues. If de-duplication of the messages is critical for your architecture, I would recommend to perform the de-duplication in the consumers.
from rabbitmq-message-deduplication.
Hi,
no problem :)
Yeah i depend on it because i execute on a idempotent messageID actions like kill, remove, stop, etc. Moby Containers. My best idea now is that before i execute it inside the Consumers i pull all messages with the ID and check if one is in ACK state. After successful execution i remove all other queued messages. But i guess that i always get the same messages back if i ask for new ones :(
Any idea or link?
Thanks!
from rabbitmq-message-deduplication.
I would highly recommend against your approach as, if you have multiple consumers, it would be very hard to ensure a consistent behaviour.
The usual approach is to rely on a shared data storage (database or key-value storage) which the consumers can use to check if the newly received message was already processed beforehand. You can check this solution as reference example.
This approach in most of my Use Cases is an overkill as it requires the management of another service (I usually implement it using Redis) and a bit of extra logic on the consumers which is not that simple to get it right.
Hence the development of this plugin.
The limit of the plugin is due to the deduplication cache size. If the cache overflows, the new elements will replace the existing ones. This means that if the problem is large enough, the plugin cannot ensure all messages will be deduplicated (you would have the same limitation with the above approach tho).
Nevertheless, if the type of messages is limited (which seems to be your case) then it should just work. Your use case seems simple enough and this plugin should fit your purpose.
I can look into adding disk persistence of the cache if you need it.
from rabbitmq-message-deduplication.
I created a new ticket for the disk persistence feature, feel free to comment there if you still need it.
Closing this issue as it went out of scope.
from rabbitmq-message-deduplication.
Related Issues (20)
- Queue level message deduplication failed sometimes. HOT 1
- Server crash HOT 2
- Support for quorums? HOT 1
- Deduplication doesn't consider the unack messages in the queue HOT 2
- Are there anyway for duplicated message to be dead letter upon published? [Question]
- Celery lost connection to broker HOT 1
- Queue crashes when is created with x-message-deduplication=true parameter on RabbitMQ 3.13.0, Plugin version 0.6.2 HOT 6
- 0.5.3 queues not working under rabbitmq 3.10.0 HOT 3
- Auto generate deduplication checksum base on payload or configurable properties
- 0.5.3 queues not working under rabbitmq 3.8.17 HOT 1
- Can key be removed from cache, after BasicAck and some time has ellapsed? HOT 3
- {:plugins_not_found, [:rabbitmq_message_deduplication]} HOT 2
- Policies support HOT 4
- Bug - when the rabbitmq is restarted the messages in a persistent queue are not deduplicated HOT 2
- Exchange level doesn't work but queue level does. What's differrence on using these two?
- Queue crashed with reason timeout to call RabbitMQMessageDeduplication.CacheManager HOT 7
- `x-cache-size` seems to be manadatory, not optional. HOT 1
- Queue level deduplication seems broken HOT 8
- Exchange info crash after upgrade to 0.6.0 HOT 5
- Debugging exchanges HOT 2
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from rabbitmq-message-deduplication.