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

Route with suspended SedaConsumer can't be stopped correctly

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.10.0
    • Fix Version/s: 2.11.1, 2.12.0
    • Component/s: None
    • Labels:
      None
    • Estimated Complexity:
      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

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

              Dates

              • Created:
                Updated:
                Resolved: