public class RecipientListTest extends CamelTestSupport {
    private Logger log = LoggerFactory.getLogger(RecipientListTest.class);

    @EndpointInject(uri = "mock:result")
    protected MockEndpoint resultEndpoint;

    @Produce(uri = "direct:start")
    protected ProducerTemplate template;

    @Produce(uri = "direct:start2")
    protected ProducerTemplate template2;

    protected ConsumerTemplate consumerTemplate;

    @EndpointInject(uri = "mock:result2")
    protected MockEndpoint resultEndpoint2;

    @EndpointInject(uri = "mock:result3")
    protected MockEndpoint resultEndpoint3;

    @EndpointInject(uri = "mock:result4")
    protected MockEndpoint resultEndpoint4;

    @Override
    protected RouteBuilder createRouteBuilder() {
        return new RouteBuilder() {
                from("direct:start2").log("=====>>>>>>>  send ${body} ").recipientList(simple("mock:result2, mock:result3, mock:result4")).parallelProcessing();


            }
        };
    }

    public void testMulticast() throws InterruptedException {
        resultEndpoint2.expectedBodiesReceived("testMulticast");
        resultEndpoint3.expectedBodiesReceived("testMulticast");
        resultEndpoint4.expectedBodiesReceived("testMulticast");
        template2.sendBody("testMulticast");
        resultEndpoint2.assertIsSatisfied();
        resultEndpoint3.assertIsSatisfied();
        resultEndpoint4.assertIsSatisfied();
    }

}