Examples of IdempotentConsumer

org.apache.camel.processor.idempotent.IdempotentConsumer
.apache.org/idempotent-consumer.html">Idempotent Consumer pattern.
This implementation supports idempotent repositories implemented as
- IdempotentRepository
- ExchangeIdempotentRepository
@see org.apache.camel.spi.IdempotentRepository @see org.apache.camel.spi.ExchangeIdempotentRepository
org.fusesource.ide.camel.model.generated.IdempotentConsumer
The Node class from Camel's IdempotentConsumerDefinition NOTE - this file is auto-generated using Velocity. DO NOT EDIT!

Examples of org.apache.camel.processor.idempotent.IdempotentConsumer

        // add as service to CamelContext so we can managed it and it ensures it will be shutdown when camel shutdowns
        routeContext.getCamelContext().addService(idempotentRepository);


        Expression expression = getExpression().createExpression(routeContext);


        return new IdempotentConsumer(expression, idempotentRepository, isEager(), isSkipDuplicate(), isRemoveOnFailure(), childProcessor);
    }

View Full Code Here

Examples of org.apache.camel.processor.idempotent.IdempotentConsumer


    @Override
    public Processor createProcessor(RouteContext routeContext) throws Exception {
        Processor childProcessor = routeContext.createProcessor(this);
        MessageIdRepository messageIdRepository = resolveMessageIdRepository(routeContext);
        return new IdempotentConsumer(getExpression().createExpression(routeContext), messageIdRepository,
                                      childProcessor);
    }

View Full Code Here

Examples of org.apache.camel.processor.idempotent.IdempotentConsumer

            if (!Boolean.getBoolean(JmxSystemPropertyKeys.DISABLED)) {
                InstrumentationProcessor interceptor = 
                    assertIsInstanceOf(InstrumentationProcessor.class, processor);
                processor = interceptor.getProcessor();
            }
            IdempotentConsumer idempotentConsumer = assertIsInstanceOf(IdempotentConsumer.class, processor);


            assertEquals("messageIdExpression", "header(myMessageId)", idempotentConsumer
                .getMessageIdExpression().toString());


            assertIsInstanceOf(MemoryMessageIdRepository.class, idempotentConsumer.getMessageIdRepository());


            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class,
                                                             unwrapErrorHandler(idempotentConsumer
                                                                 .getNextProcessor()));
            assertEquals("Endpoint URI", "seda:b", sendProcessor.getDestination().getEndpointUri());
        }
    }

View Full Code Here

Examples of org.apache.camel.processor.idempotent.IdempotentConsumer

            (IdempotentRepository<String>) resolveMessageIdRepository(routeContext);


        Expression expression = getExpression().createExpression(routeContext);
        // should be eager by default
        boolean isEager = isEager() != null ? isEager() : true;
        return new IdempotentConsumer(expression, idempotentRepository, isEager, childProcessor);
    }

View Full Code Here

Examples of org.fusesource.ide.camel.model.generated.IdempotentConsumer

        imageProvider.addIconsForClass(new Delay());
        imageProvider.addIconsForClass(new DynamicRouter());
        imageProvider.addIconsForClass(new Enrich());
        imageProvider.addIconsForClass(new Filter());
        imageProvider.addIconsForClass(new Finally());
        imageProvider.addIconsForClass(new IdempotentConsumer());
        imageProvider.addIconsForClass(new InOnly());
        imageProvider.addIconsForClass(new InOut());
        imageProvider.addIconsForClass(new Intercept());
        imageProvider.addIconsForClass(new InterceptFrom());
        imageProvider.addIconsForClass(new InterceptSendToEndpoint());

View Full Code Here

0 1 2 3

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.