List of addInterceptStrategy() Examples

Examples of addInterceptStrategy()

org.apache.camel.CamelContext.addInterceptStrategy()
Adds the given interceptor strategy @param interceptStrategy the strategy
org.apache.camel.Channel.addInterceptStrategy()
Adds a {@link org.apache.camel.spi.InterceptStrategy} to apply each {@link Exchange} beforeits routed to the next {@link Processor}. @param strategy the intercept strategy
org.apache.camel.model.ProcessorDefinition.addInterceptStrategy()
org.apache.camel.model.RouteDefinition.addInterceptStrategy()

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

        tracer.setTraceExceptions(true);
        tracer.setLogStackTrace(true);
        tracer.setUseJpa(false);
        tracer.setDestination(context.getEndpoint("mock:traced"));


        context.addInterceptStrategy(tracer);
        tracer.start();


        return context;
    }

View Full Code Here

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

        tracer.setTraceExceptions(true);
        tracer.setLogStackTrace(true);
        tracer.setUseJpa(false);
        tracer.setDestination(context.getEndpoint("mock:traced"));


        context.addInterceptStrategy(tracer);
        tracer.start();


        return context;
    }

View Full Code Here

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

        tracer.setTraceExceptions(true);
        tracer.setLogStackTrace(true);
        tracer.setUseJpa(false);
        tracer.setDestination(context.getEndpoint("mock:traced"));


        context.addInterceptStrategy(tracer);
        tracer.start();


        return context;
    }

View Full Code Here

Examples of org.apache.camel.Channel.addInterceptStrategy()


        // add interceptor strategies to the channel must be in this order: camel context, route context, local
        addInterceptStrategies(routeContext, channel, routeContext.getCamelContext().getInterceptStrategies());
        addInterceptStrategies(routeContext, channel, routeContext.getInterceptStrategies());
        if (routeContext.getManagedInterceptStrategy() != null) {
            channel.addInterceptStrategy(routeContext.getManagedInterceptStrategy());
        }
        addInterceptStrategies(routeContext, channel, this.getInterceptStrategies());


        // must do this ugly cast to avoid compiler error on AIX/HP-UX
        ProcessorDefinition defn = (ProcessorDefinition) this;

View Full Code Here

Examples of org.apache.camel.Channel.addInterceptStrategy()


        // add interceptor strategies to the channel must be in this order: camel context, route context, local
        addInterceptStrategies(routeContext, channel, routeContext.getCamelContext().getInterceptStrategies());
        addInterceptStrategies(routeContext, channel, routeContext.getInterceptStrategies());
        if (routeContext.getManagedInterceptStrategy() != null) {
            channel.addInterceptStrategy(routeContext.getManagedInterceptStrategy());
        }
        addInterceptStrategies(routeContext, channel, this.getInterceptStrategies());


        // must do this ugly cast to avoid compiler error on HP-UX
        ProcessorDefinition defn = (ProcessorDefinition) this;

View Full Code Here

Examples of org.apache.camel.Channel.addInterceptStrategy()


        // add interceptor strategies to the channel must be in this order: camel context, route context, local
        addInterceptStrategies(routeContext, channel, routeContext.getCamelContext().getInterceptStrategies());
        addInterceptStrategies(routeContext, channel, routeContext.getInterceptStrategies());
        if (routeContext.getManagedInterceptStrategy() != null) {
            channel.addInterceptStrategy(routeContext.getManagedInterceptStrategy());
        }
        addInterceptStrategies(routeContext, channel, this.getInterceptStrategies());


        // must do this ugly cast to avoid compiler error on HP-UX
        ProcessorDefinition defn = (ProcessorDefinition) this;

View Full Code Here

Examples of org.apache.camel.Channel.addInterceptStrategy()


        // add interceptor strategies to the channel must be in this order: camel context, route context, local
        addInterceptStrategies(routeContext, channel, routeContext.getCamelContext().getInterceptStrategies());
        addInterceptStrategies(routeContext, channel, routeContext.getInterceptStrategies());
        if (routeContext.getManagedInterceptStrategy() != null) {
            channel.addInterceptStrategy(routeContext.getManagedInterceptStrategy());
        }
        addInterceptStrategies(routeContext, channel, this.getInterceptStrategies());


        // must do this ugly cast to avoid compiler error on HP-UX
        ProcessorDefinition defn = (ProcessorDefinition) this;

View Full Code Here

Examples of org.apache.camel.model.ProcessorDefinition.addInterceptStrategy()


        // only needed to register on the first output as all rotues will pass through this one
        ProcessorDefinition out = routeContext.getRoute().getOutputs().get(0);


        // add an intercept strategy that counts when the route sends to any of its outputs
        out.addInterceptStrategy(new InterceptStrategy() {
            public Processor wrapProcessorInInterceptors(ProcessorDefinition processorDefinition, Processor target, Processor nextTarget) throws Exception {
                if (registeredRoutes.containsKey(endpoint)) {
                    // do not double wrap
                    return target;
                }

View Full Code Here

Examples of org.apache.camel.model.ProcessorDefinition.addInterceptStrategy()

            break;
        }


        // add an intercept strategy that counts when the route sends to any of its outputs
        if (out != null) {
            out.addInterceptStrategy(new InterceptStrategy() {
                public Processor wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition definition,
                                                             Processor target, Processor nextTarget) throws Exception {
                    if (registeredRoutes.containsKey(endpoint)) {
                        // do not double wrap
                        return target;

View Full Code Here

Examples of org.apache.camel.model.ProcessorDefinition.addInterceptStrategy()


        // only needed to register on the first output as all rotues will pass through this one
        ProcessorDefinition out = routeContext.getRoute().getOutputs().get(0);


        // add an intercept strategy that counts when the route sends to any of its outputs
        out.addInterceptStrategy(new InterceptStrategy() {
            public Processor wrapProcessorInInterceptors(ProcessorDefinition processorDefinition, Processor target, Processor nextTarget) throws Exception {
                if (registeredRoutes.containsKey(endpoint)) {
                    // do not double wrap
                    return target;
                }

View Full Code Here

0 1

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.