Re: Seeing slow performance when placing messages onto JMS topic

[Christian Müller]

Sorry for the delayed response. My inbox is a bit full...

I set up the following test with Camel 2.10.2:

public class CamelActiveMQTopicPerformanceTest extends CamelTestSupport {

    private int counter = 1000;
    private BrokerService broker;

    @Before
    public void setUp() throws Exception {
        broker = new BrokerService();
        broker.setPersistent(true);
        broker.setUseJmx(false);
        broker.addConnector("tcp://localhost:61616");
        broker.start();

        super.setUp();
    }

    @After
    public void tearDown() throws Exception {
        super.tearDown();

        broker.stop();
    }

    @Test
    public void test() throws InterruptedException {
        template.setDefaultEndpointUri("direct:start");

        long start = System.currentTimeMillis();
        for (int i = 0; i < counter; i++) {
            template.sendBody("test " + i);
        }
        long end = System.currentTimeMillis();

        System.out.println("sending " + counter + " messages tooks "+ (end
- start) + " ms");
    }



    @Override
    protected JndiRegistry createRegistry() throws Exception {
        JndiRegistry registry = super.createRegistry();
        registry.bind("activemq",
ActiveMQComponent.activeMQComponent("tcp://localhost:61616"));
        return registry;
    }



    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            public void configure() throws Exception {
                from("direct:start")
                    .to("activemq:topic:test?deliveryPersistent=false");
            }
        };
    }
}

And got the log output: sending 1000 messages tooks 5968 ms
Which means less than 6ms per message. How did you measure the performance?
What number did you expect?

Best,
Christian

On Fri, Nov 16, 2012 at 7:07 PM, Edwin <edwin.rabbi...@gmail.com> wrote:

> ?deliveryPersistent=false
>