Examples of PipelineDefinition

org.apache.camel.model.PipelineDefinition
Represents an XML <pipeline/> element which can be used to define an explicit pipeline; or to define a specific pipeline within a <multicast> block @version $Revision: 936869 $

Examples of org.apache.camel.model.PipelineDefinition

    }


    @SuppressWarnings("rawtypes")
    @Override
    public ProcessorDefinition createCamelDefinition() {
        PipelineDefinition answer = new PipelineDefinition();


        answer.setInheritErrorHandler(toXmlPropertyValue(PROPERTY_INHERITERRORHANDLER, Objects.<Boolean>getField(this, "inheritErrorHandler")));


        super.savePropertiesToCamelDefinition(answer);
        return answer;
    }

View Full Code Here

Examples of org.apache.camel.model.PipelineDefinition

    @Override
    protected void loadPropertiesFromCamelDefinition(ProcessorDefinition processor) {
        super.loadPropertiesFromCamelDefinition(processor);


        if (processor instanceof PipelineDefinition) {
            PipelineDefinition node = (PipelineDefinition) processor;


            this.setInheritErrorHandler(Objects.<Boolean>getField(node, "inheritErrorHandler"));
        } else {
            throw new IllegalArgumentException("ProcessorDefinition not an instanceof PipelineDefinition. Was " + processor.getClass().getName());
        }

View Full Code Here

Examples of org.apache.camel.model.PipelineDefinition

     *
     * @return the builder to build the nodes.
     */
    public ProcessorDefinition<?> replace() {
        RouteDefinition route = builder.getOriginalRoute();
        PipelineDefinition answer = new PipelineDefinition();
        if (id != null) {
            builder.getAdviceWithTasks().add(AdviceWithTasks.replaceById(route, id, answer, selectFirst, selectLast, selectFrom, selectTo));
        } else if (toString != null) {
            builder.getAdviceWithTasks().add(AdviceWithTasks.replaceByToString(route, toString, answer, selectFirst, selectLast, selectFrom, selectTo));
        } else if (type != null) {

View Full Code Here

Examples of org.apache.camel.model.PipelineDefinition

     *
     * @return the builder to build the nodes.
     */
    public ProcessorDefinition<?> before() {
        RouteDefinition route = builder.getOriginalRoute();
        PipelineDefinition answer = new PipelineDefinition();
        if (id != null) {
            builder.getAdviceWithTasks().add(AdviceWithTasks.beforeById(route, id, answer, selectFirst, selectLast, selectFrom, selectTo));
        } else if (toString != null) {
            builder.getAdviceWithTasks().add(AdviceWithTasks.beforeByToString(route, toString, answer, selectLast, selectFirst, selectFrom, selectTo));
        } else if (type != null) {

View Full Code Here

Examples of org.apache.camel.model.PipelineDefinition

     *
     * @return the builder to build the nodes.
     */
    public ProcessorDefinition<?> after() {
        RouteDefinition route = builder.getOriginalRoute();
        PipelineDefinition answer = new PipelineDefinition();
        if (id != null) {
            builder.getAdviceWithTasks().add(AdviceWithTasks.afterById(route, id, answer, selectFirst, selectLast, selectFrom, selectTo));
        } else if (toString != null) {
            builder.getAdviceWithTasks().add(AdviceWithTasks.afterByToString(route, toString, answer, selectLast, selectFirst, selectFrom, selectTo));
        } else if (type != null) {

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.