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

Route with suspended SedaConsumer can't be stopped correctly

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.10.0
    • 2.11.1, 2.12.0
    • None
    • None
    • Unknown

    Description

      Route with suspended SedaConsumer can't be stopped correctly. Here is test:

       @Test
          public void testOriginalSedaShutdownSuspended() throws Exception {
              SedaEndpoint endpoint = context().getEndpoint("seda:test", SedaEndpoint.class);
              context().addRouteDefinition(new RouteDefinition()
                      .id("testRoute")
                      .from(endpoint)
                      .to("log:body")
              );
              Set<SedaConsumer> consumers = endpoint.getConsumers();
              Assert.assertFalse(consumers.isEmpty());
              for (SedaConsumer sedaConsumer: consumers) {
                  sedaConsumer.suspend();
              }
              Assert.assertTrue(context().stopRoute("testRoute", 2, TimeUnit.SECONDS, true));
          }
      

      Attachments

        Activity

          People

            davsclaus Claus Ibsen
            tivv Vitalii Tymchyshyn
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: