How does ActiveMQ detect slow consumer -


  1. what exact logic activemq uses consumer slow consumer?
  2. in case of multiple consumers slow take account other consumers connected same topic?

it great if code pointers same can provided

  1. look @ line 100 , add method in topicsubscription.java.

  2. 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

Popular posts from this blog

monitor web browser programmatically in Android? -

Shrink a YouTube video to responsive width -

wpf - PdfWriter.GetInstance throws System.NullReferenceException -