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


        IdempotentRepository<String> idempotentRepository =
            (IdempotentRepository<String>) resolveMessageIdRepository(routeContext);


        Expression expression = getExpression().createExpression(routeContext);
        return new IdempotentConsumer(expression, idempotentRepository, eager, childProcessor);
    }

View Full Code Here

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

            assertEquals("From endpoint", "seda://a", key.getEndpointUri());


            EventDrivenConsumerRoute consumer = assertIsInstanceOf(EventDrivenConsumerRoute.class, route);
            Channel channel = unwrapChannel(consumer.getProcessor());


            IdempotentConsumer idempotentConsumer = assertIsInstanceOf(IdempotentConsumer.class, channel.getNextProcessor());
            assertEquals("messageIdExpression", "header(myMessageId)", idempotentConsumer.getMessageIdExpression().toString());


            assertIsInstanceOf(MemoryIdempotentRepository.class, idempotentConsumer.getIdempotentRepository());
            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class, unwrapChannel(idempotentConsumer.getProcessor()).getNextProcessor());
            assertEquals("Endpoint URI", "seda://b", sendProcessor.getDestination().getEndpointUri());
        }
    }

View Full Code Here

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

    public Processor createProcessor(RouteContext routeContext) throws Exception {
        Processor childProcessor = routeContext.createProcessor(this);
        IdempotentRepository<String> idempotentRepository = 
            (IdempotentRepository<String>) resolveMessageIdRepository(routeContext);
        Expression expression = getExpression().createExpression(routeContext);
        return new IdempotentConsumer(expression, idempotentRepository, eager, 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);
        IdempotentRepository idempotentRepository = resolveMessageIdRepository(routeContext);
        Expression expression = getExpression().createExpression(routeContext);
        return new IdempotentConsumer(expression, idempotentRepository, eager, childProcessor);
    }

View Full Code Here

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

            assertEquals("From endpoint", "seda://a", key.getEndpointUri());


            EventDrivenConsumerRoute consumer = assertIsInstanceOf(EventDrivenConsumerRoute.class, route);
            Channel channel = unwrapChannel(consumer.getProcessor());


            IdempotentConsumer idempotentConsumer = assertIsInstanceOf(IdempotentConsumer.class, channel.getNextProcessor());
            assertEquals("messageIdExpression", "header(myMessageId)", idempotentConsumer.getMessageIdExpression().toString());


            assertIsInstanceOf(MemoryIdempotentRepository.class, idempotentConsumer.getIdempotentRepository());
            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class, unwrapChannel(idempotentConsumer.getProcessor()).getNextProcessor());
            assertEquals("Endpoint URI", "seda://b", sendProcessor.getDestination().getEndpointUri());
        }
    }

View Full Code Here

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

            assertEquals("From endpoint", "direct://a", key.getEndpointUri());


            EventDrivenConsumerRoute consumer = assertIsInstanceOf(EventDrivenConsumerRoute.class, route);
            Channel channel = unwrapChannel(consumer.getProcessor());


            IdempotentConsumer idempotentConsumer = assertIsInstanceOf(IdempotentConsumer.class, channel.getNextProcessor());
            assertEquals("messageIdExpression", "header(myMessageId)", idempotentConsumer.getMessageIdExpression().toString());


            assertIsInstanceOf(MemoryIdempotentRepository.class, idempotentConsumer.getIdempotentRepository());
            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class, unwrapChannel(idempotentConsumer.getProcessor()).getNextProcessor());
            assertEquals("Endpoint URI", "direct://b", sendProcessor.getDestination().getEndpointUri());
        }
    }

View Full Code Here

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

            assertEquals("From endpoint", "seda://a", key.getEndpointUri());


            EventDrivenConsumerRoute consumer = assertIsInstanceOf(EventDrivenConsumerRoute.class, route);
            Channel channel = unwrapChannel(consumer.getProcessor());


            IdempotentConsumer idempotentConsumer = assertIsInstanceOf(IdempotentConsumer.class, channel.getNextProcessor());
            assertEquals("messageIdExpression", "header(myMessageId)", idempotentConsumer.getMessageIdExpression().toString());


            assertIsInstanceOf(MemoryIdempotentRepository.class, idempotentConsumer.getIdempotentRepository());
            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class, unwrapChannel(idempotentConsumer.getProcessor()).getNextProcessor());
            assertEquals("Endpoint URI", "seda://b", sendProcessor.getDestination().getEndpointUri());
        }
    }

View Full Code Here

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

        return processor;
    }


    @Override
    protected Processor wrapProcessor(Processor processor) {
        return new IdempotentConsumer(messageIdExpression, messageIdRegistry, processor);
    }

View Full Code Here

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

        for (Route route : routes) {
            Endpoint key = route.getEndpoint();
            assertEquals("From endpoint", "queue:a", key.getEndpointUri());
            Processor processor = getProcessorWithoutErrorHandler(route);


            IdempotentConsumer idempotentConsumer = assertIsInstanceOf(IdempotentConsumer.class, processor);


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


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


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

View Full Code Here

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

            assertEquals("From endpoint", "seda://a", key.getEndpointUri());


            EventDrivenConsumerRoute consumer = assertIsInstanceOf(EventDrivenConsumerRoute.class, route);
            Channel channel = unwrapChannel(consumer.getProcessor());


            IdempotentConsumer idempotentConsumer = assertIsInstanceOf(IdempotentConsumer.class, channel.getNextProcessor());
            assertEquals("messageIdExpression", "header(myMessageId)", idempotentConsumer.getMessageIdExpression().toString());


            assertIsInstanceOf(MemoryIdempotentRepository.class, idempotentConsumer.getIdempotentRepository());
            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class, unwrapChannel(idempotentConsumer.getProcessor()).getNextProcessor());
            assertEquals("Endpoint URI", "seda://b", sendProcessor.getDestination().getEndpointUri());
        }
    }

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.