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

Always ack even on fails exchange

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: 2.24.1, 3.0.0.M4
    • Fix Version/s: None
    • Component/s: camel-rabbitmq
    • Labels:
      None
    • Estimated Complexity:
      Unknown

      Description

      Messages are always ack (consumer) even on exception
      https://stackoverflow.com/questions/48941888/rabbitmq-and-camel-2-20-auto-acknowledges-even-when-autoack-false

      @Override
          public void configure() throws Exception {
      
              from(rabbitMq())
                      .routeId(ROUTE_ID)
                      .throwException(new Exception("2222"))
                      .log("test");
          }
      
      private String rabbitMq() {
              StringBuilder rabbit = new StringBuilder("rabbitmq:").append("test");
      
              rabbit.append("?queue=");
              rabbit.append("test");
              rabbit.append("&prefetchEnabled=");
              rabbit.append(true);
              rabbit.append("&concurrentConsumers=");
              rabbit.append(1);
              rabbit.append("&threadPoolSize=");
              rabbit.append(1);
              rabbit.append("&prefetchCount=");
              rabbit.append(50);
      
              return rabbit.toString();
          }
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              michael992 michael elbaz
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: