Examples of addRouteDefinitions()


Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        RoutePolicy policy = (RoutePolicy)applicationContext.getBean(policyBeanName);
        assertTrue(getTestType() == TestType.SIMPLE
            ? policy instanceof SimpleScheduledRoutePolicy
            : policy instanceof CronScheduledRoutePolicy);
        routes.get(0).routePolicy(policy);
        context.addRouteDefinitions(routes);
        context.start();
        return context;
    }
   
    public ClassPathXmlApplicationContext getApplicationContext() {
View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        if (camelContexts.size() == 1) {
            return camelContexts.get(0);
        } else {
            ModelCamelContext answer = new DefaultCamelContext();
            for (CamelContext camelContext : camelContexts) {
                answer.addRouteDefinitions(((ModelCamelContext)camelContext).getRouteDefinitions());
            }
            return answer;
        }
    }
View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        if (camelContexts.size() == 1) {
            return camelContexts.get(0);
        } else {
            ModelCamelContext answer = new DefaultCamelContext();
            for (CamelContext camelContext : camelContexts) {
                answer.addRouteDefinitions(((ModelCamelContext)camelContext).getRouteDefinitions());
            }
            return answer;
        }
    }
View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        if (camelContexts.size() == 1) {
            return camelContexts.get(0);
        } else {
            DefaultCamelContext answer = new DefaultCamelContext();
            for (CamelContext camelContext : camelContexts) {
                answer.addRouteDefinitions(camelContext.getRouteDefinitions());
            }
            return answer;
        }
    }
View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        if (getTestType() == TestType.SIMPLE) {
            routes.get(0).setRoutePolicy((SimpleScheduledRoutePolicy) applicationContext.getBean(policyBeanName));           
        } else {
            routes.get(0).setRoutePolicy((CronScheduledRoutePolicy) applicationContext.getBean(policyBeanName));
        }
        context.addRouteDefinitions(routes);
        context.start();
        return context;
    }

    public ClassPathXmlApplicationContext getApplicationContext() {
View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        return false;
    }

    public CamelContext createContext(Collection<RouteDefinition> routes) throws Exception {
        ModelCamelContext context = new DefaultCamelContext();
        context.addRouteDefinitions(routes);
        return context;
    }

    public CamelContext camelContext() throws Exception {
        return createContext(contextElement.getRoutes());
View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        if (camelContexts.size() == 1) {
            return camelContexts.get(0);
        } else {
            ModelCamelContext answer = new DefaultCamelContext();
            for (CamelContext camelContext : camelContexts) {
                answer.addRouteDefinitions(((ModelCamelContext)camelContext).getRouteDefinitions());
            }
            return answer;
        }
    }
View Full Code Here

Examples of org.apache.camel.impl.DefaultCamelContext.addRouteDefinitions()

        return false;
    }

    public CamelContext createContext(Collection<RouteDefinition> routes) throws Exception {
        ModelCamelContext context = new DefaultCamelContext();
        context.addRouteDefinitions(routes);
        return context;
    }

    public CamelContext camelContext() throws Exception {
        return createContext(contextElement.getRoutes());
View Full Code Here

Examples of org.apache.camel.model.ModelCamelContext.addRouteDefinitions()

        if (camelContexts.size() == 1) {
            return camelContexts.get(0);
        } else {
            ModelCamelContext answer = new DefaultCamelContext();
            for (CamelContext camelContext : camelContexts) {
                answer.addRouteDefinitions(((ModelCamelContext)camelContext).getRouteDefinitions());
            }
            return answer;
        }
    }
View Full Code Here

Examples of org.apache.camel.model.ModelCamelContext.addRouteDefinitions()

        ModelCamelContext camelContext = getContext();
        if (camelContext == null) {
            throw new IllegalArgumentException("CamelContext has not been injected!");
        }
        getRouteCollection().setCamelContext(camelContext);
        camelContext.addRouteDefinitions(getRouteCollection().getRoutes());
    }

    public void setRouteCollection(RoutesDefinition routeCollection) {
        this.routeCollection = routeCollection;
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.