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

Temporary reply queues being created with main endpoint autoAck setting

    XMLWordPrintableJSON

Details

    • 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

            davsclaus Claus Ibsen
            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