Vitalii Tymchyshyn created CAMEL-6390:
-----------------------------------------

             Summary:  Route with suspended SedaConsumer can't be stopped 
correctly
                 Key: CAMEL-6390
                 URL: https://issues.apache.org/jira/browse/CAMEL-6390
             Project: Camel
          Issue Type: Bug
    Affects Versions: 2.10.0
            Reporter: Vitalii Tymchyshyn


Route with suspended SedaConsumer can't be stopped correctly. Here is test:
{code}
 @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));
    }
{code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to