Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-12746

Temporary reply queues being created with main endpoint autoAck setting

    XMLWordPrintableJSON

    Details

    • Estimated Complexity:
      Novice

      Description

      As discussed here:

      http://camel.465427.n5.nabble.com/Camel-with-Rabbitmq-messages-in-temp-reply-queue-not-being-acked-td5822286.html

      When temporary reply queues are used on InOut capable routes with autoAck set to false on the main queue(s) the reply messages keep piling up in the temporary queue in an un-acked state until a consumer restart.

      This can be prevented with a change to the TemporaryQueueReplyManager line 139 to always start the consumer of temprary queues with auto acknowledge mode of true.

      Changing this:

          private void start() throws IOException

      {         tag = channel.basicConsume(getReplyTo(), endpoint.isAutoAck(), this);     }

      To:

          private void start() throws IOException

      {         tag = channel.basicConsume(getReplyTo(), *true*, this);     }

       

        Attachments

          Activity

            People

            • Assignee:
              davsclaus Claus Ibsen
              Reporter:
              Andersons Valdis
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - 24h
                24h
                Remaining:
                Remaining Estimate - 24h
                24h
                Logged:
                Time Spent - Not Specified
                Not Specified