RabbitMQ and relationship between channel and connection

by

  1. A Connection represents a real TCP connection to the message broker, whereas a Channel is a virtual connection (AMQP connection) inside it. This way you can use as many (virtual) connections as you want inside your application without overloading the broker with TCP connections.

  2. You can use one Channel for everything. However, if you have multiple threads, it’s suggested to use a different Channel for each thread.

    Channel thread-safety in Java Client API Guide:

    Channel instances are safe for use by multiple threads. Requests into
    a Channel are serialized, with only one thread being able to run a
    command on the Channel at a time. Even so, applications should prefer
    using a Channel per thread instead of sharing the same Channel across
    multiple threads.

    There is no direct relation between Channel and Queue. A Channel is used to send AMQP commands to the broker. This can be the creation of a queue or similar, but these concepts are not tied together.

  3. Each Consumer runs in its own thread allocated from the consumer thread pool. If multiple Consumers are subscribed to the same Queue, the broker uses round-robin to distribute the messages between them equally. See Tutorial two: “Work Queues”.

    It is also possible to attach the same Consumer to multiple Queues.
    You can understand Consumers as callbacks. These are called everytime a message arrives on a Queue the Consumer is bound to. For the case of the Java Client, each Consumers has a method handleDelivery(...), which represents the callback method. What you typically do is, subclass DefaultConsumer and override handleDelivery(...). Note: If you attach the same Consumer instance to multiple queues, this method will be called by different threads. So take care of synchronization if necessary.

More Related Contents:

  1. Technique or utility to minimize Java “warm-up” time?
  2. RabbitMQ / AMQP: single queue, multiple consumers for same message?
  3. Spring RabbitMQ – using manual channel acknowledgement on a service with @RabbitListener configuration
  4. When to use Spring Integration vs. Camel?
  5. Multiple commands using JSch
  6. How do i find the first un-escaped quotes in Java?
  7. What is the Java ?: operator called and what does it do?
  8. How to get a resource id with a known resource name?
  9. Get nested JSON object with GSON using retrofit
  10. Difference between paint, paintComponent and paintComponents in Swing
  11. How to convert a Map to List in Java?
  12. Why does Java have an “unreachable statement” compiler error?
  13. Why to use SwingUtilities.invokeLater in main method?
  14. How to set specific Java version to Maven?
  15. Why does parallel stream with lambda in static initializer cause a deadlock?
  16. Explicit type casting example in Java
  17. Java JTree directory structure from file paths
  18. Netbeans – Error: Could not find or load main class
  19. Difference between paint() and paintcomponent()?
  20. TableCellRenderer and how to refresh Cell background without using JTable.repaint()
  21. Java byte array contains negative numbers
  22. How to delete a folder with files using Java
  23. Using curl command in java
  24. Spring-Data FETCH JOIN with Paging is not working
  25. Can we call a static method with a null object in Java? If so, how?
  26. debug java program step by step in Eclipse
  27. How to override DNS in HTTP connections in Java
  28. Maven adding mainClass in pom.xml with the right folder path
  29. How Synchronization works in Java?
  30. Get last element of Stream/List in a one-liner

Leave a Comment