Package org.apache.camel.component.seda

Examples of org.apache.camel.component.seda.SedaComponent$QueueReference


     * for a {@link UriEndpointComponent}
     */
    @Test
    public void testConfigureAnExistingSedaEndpoint() throws Exception {
        SedaEndpoint endpoint = context.getEndpoint("seda:cheese?concurrentConsumers=5", SedaEndpoint.class);
        SedaComponent component = endpoint.getComponent();
        ComponentConfiguration configuration = component.createComponentConfiguration();

        assertEquals("concurrentConsumers", 5, endpoint.getConcurrentConsumers());
        assertEquals("concurrentConsumers", 5,
                configuration.getEndpointParameter(endpoint, "concurrentConsumers"));

View Full Code Here


    @Override
    public CamelContext createCamelContext() {
        CamelContext context = new DefaultCamelContext();
        // plug in a seda component, as we don't really need an embedded broker
        context.addComponent("activemq", new SedaComponent());
        return context;
    }
View Full Code Here

TOP

Related Classes of org.apache.camel.component.seda.SedaComponent$QueueReference

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.