GroceriesTests.java

    @Test
    public void test_fruit_is_routed_to_the_fruits_processor_via_groceries_queue() throws InterruptedException {
        //given
        Fruit apple = new Fruit("apple", "England");
        ProducerTemplate producer = camelContext.createProducerTemplate();

        //when
        producer.sendBody(GroceriesRouteBuilder.GROCERIES_QUEUE, apple);

        //then
        fruitProcessor.expectedBodiesReceived(apple);
        fruitProcessor.assertIsSatisfied();

        vegetableProcessor.expectedMessageCount(0);
        vegetableProcessor.assertIsSatisfied();
    }

    @Test
    public void test_vegetable_is_routed_to_the_fruits_processor_via_groceries_queue() throws InterruptedException {
        //given
        Vegetable potato = new Vegetable("potato", "Scotland");
        ProducerTemplate producer = camelContext.createProducerTemplate();

        //when
        producer.sendBody(GroceriesRouteBuilder.GROCERIES_QUEUE, potato);

        //then
        vegetableProcessor.expectedBodiesReceived(potato);
        vegetableProcessor.assertIsSatisfied();

        fruitProcessor.expectedMessageCount(0);
        fruitProcessor.assertIsSatisfied();
    }