All Questions
8 questions
0
votes
1
answer
2k
views
How to configure RabbitMQ to serve multiple queues to multiple consumers equally
I have a RabbitMQ broker with multiple queues set up. On the client side (Java) I have multiple consumers which are all listening to their queue like so:
QUEUE_1 -> DataConsumer1;
QUEUE_2 -> ...
- 1,877
0
votes
1
answer
79
views
how to concurrently put an element (might exist) without lock in ConcurrentHashMap?
I'm writing a simple message queue program and I have multiple producers and multiple serializer (consumer is not considered right now). The producer specifies which queue it want to send message to ...
- 330
0
votes
1
answer
329
views
Could this queue implementation enable lower latency messaging, when compared to the LMAX disruptor?
I've developed a queue which allows a single consumer and producer to offer/poll elements from the queue concurrently without synchronization or CAS operations on every offer/poll. Instead there only ...
- 827
1
vote
1
answer
518
views
Java - MDB - How to avoid concurrency issue
We have MDB implemented which take user input and processing parallel. We have a limit check on user data (like number of phone numbers user can have).
The problem I'm facing is two different ...
- 4,951
10
votes
2
answers
2k
views
How does wait / notify work at the JVM level?
Wait and notify seem like messages that are passed between threads, if this is true there must be queues for buffering these messages. If so then there must be atomic operations for adding messages to ...
- 827
3
votes
1
answer
9k
views
Java: Implement own message queue (threadsafe)
The task is to implement my own messagequeue that is thread safe.
My approach:
public class MessageQueue {
/**
* Number of strings (messages) that can be stored in the queue.
*/
...
- 355
3
votes
2
answers
2k
views
LMAX Disruptor vs JMS Provider
I was told a while back about the LMAX disruptor and how performant it is compared with standard message queues. I downloaded the latest version and see that it's an ordinary JAR that contains lots of ...
- 57k
0
votes
1
answer
657
views
elegant way of graceful stopping queue with periodic consumers by timeout
I have a queue with multiple producers - one consumer. The consumer runs periodically and drains the queue fully (no messages left after).
A graceful algorithm should run the consumer and wait for it ...
- 1,709