@@ -0,0 +1,992 @@
+package com.github.tatsuyafw.camel.component.fluentd;%0A%0Aimport org.apache.camel.builder.RouteBuilder;%0Aimport org.apache.camel.component.mock.MockEndpoint;%0Aimport org.apache.camel.test.junit4.CamelTestSupport;%0Aimport org.junit.Test;%0A%0Aimport java.util.HashMap;%0Aimport java.util.Map;%0A%0Apublic class FluentdProducerTest extends CamelTestSupport %7B%0A%0A    @Test%0A    public void testFluentdProducer() throws Exception %7B%0A        MockEndpoint mock = getMockEndpoint(%22mock:result%22);%0A        mock.expectedMessageCount(1);%0A%0A        Map%3CString, String%3E body = new HashMap%3C%3E();%0A        body.put(%22test%22, %22value%22);%0A        template.sendBody(%22direct:start%22, body);%0A%0A        assertMockEndpointsSatisfied();%0A    %7D%0A%0A    @Override%0A    protected RouteBuilder createRouteBuilder() %7B%0A        return new RouteBuilder() %7B%0A            @Override%0A            public void configure() throws Exception %7B%0A                from(%22direct:start%22).to(%22fluentd:127.0.0.1/tag.test%22).to(%22mock:result%22);%0A            %7D%0A        %7D;%0A    %7D%0A%0A%7D%0A

Add the Producer test