How does ActiveMQ detect slow consumer -
- what exact logic activemq uses consumer slow consumer?
- in case of multiple consumers slow take account other consumers connected same topic?
it great if code pointers same can provided
look @ line 100 , add method in topicsubscription.java.
a slow consumer 1 slow consumer lacking behind in receiving published messages. how "fast" other consumers not matter slow consumer. it's more difference between produced , consumed messages. read code details or rephrase question more specific.
Comments
Post a Comment