Examples of org.apache.camel.CamelContext.addEndpoint()

org.apache.camel.CamelContext.addEndpoint()
Adds the endpoint to the context using the given URI. @param uri the URI to be used to resolve this endpoint @param endpoint the endpoint to be added to the context @return the old endpoint that was previously registered or null if none was registered @throws Exception if the new endpoint could not be started or the old endpoint could not be stopped

        CamelContext context = createCamelContext();
        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);
        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));
        context.removeComponent("log");
        context.stop();


        List<String> expectedEvents = Arrays.asList("onContextStart", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd",
                                                    "onServiceAdd", "onComponentAdd", "onEndpointAdd", "onComponentRemove", "onContextStop");

View Full Code Here

        CamelContext context = createCamelContext();
        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);
        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));
        context.removeComponent("log");
        context.stop();


        List<String> expectedEvents = Arrays.asList("onContextStart", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd",
                                                    "onServiceAdd", "onServiceAdd", "onComponentAdd", "onEndpointAdd", "onComponentRemove", "onContextStop");

View Full Code Here

        CamelContext context = createCamelContext();
        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);
        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));
        context.removeComponent("log");
        context.stop();


        List<String> expectedEvents = Arrays.asList("onServiceAdd", "onThreadPoolAdd", "onContextStart", "onServiceAdd",
                "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd",

View Full Code Here

        CamelContext context = createCamelContext();
        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);
        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));
        context.removeComponent("log");
        context.stop();


        List<String> expectedEvents = Arrays.asList("onThreadPoolAdd", "onContextStart", "onServiceAdd", "onServiceAdd",
                "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd",

View Full Code Here

        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);


        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));


        context.removeComponent("log");


        context.stop();

View Full Code Here

        CamelContext context = createCamelContext();
        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);
        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));
        context.removeComponent("log");
        context.stop();


        List<String> expectedEvents = Arrays.asList("onContextStart", "onServiceAdd", "onServiceAdd", "onServiceAdd",
                "onServiceAdd", "onServiceAdd", "onServiceAdd", "onServiceAdd", "onThreadPoolAdd", "onThreadPoolAdd",

View Full Code Here


    @Override
    protected CamelContext createCamelContext() throws Exception {
        CamelContext context = super.createCamelContext();


        context.addEndpoint("fail", new DefaultEndpoint() {
            public Producer createProducer() throws Exception {
                return new DefaultProducer(this) {
                    public void process(Exchange exchange) throws Exception {
                        exchange.setException(new IllegalArgumentException("Damn"));
                    }

View Full Code Here

            public boolean isSingleton() {
                return true;
            }
        });


        context.addEndpoint("not-fail", new DefaultEndpoint() {
            public Producer createProducer() throws Exception {
                return new DefaultProducer(this) {
                    public void process(Exchange exchange) throws Exception {
                        // noop
                    }

View Full Code Here

        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);


        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));


        context.removeComponent("log");


        context.stop();

View Full Code Here

        context.start();


        Component log = new LogComponent();
        context.addComponent("log", log);


        context.addEndpoint("log:/foo", log.createEndpoint("log://foo"));


        context.removeComponent("log");


        context.stop();

View Full Code Here

0 1 2

TOP

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.