Prueba Camel con MockEndpoints

Question

Tengo una serie de componentes "interconectados" que se comunican a través de las colas de mensajes de ActiveMQ. Cada componente usa Camel para tratar cada una de estas colas como un Endpoint. Cada componente utiliza el mismo patrón básico:

donde cada componente consume mensajes fuera de una cola de entrada, procesa el mensaje (s), y luego coloca 1+ mensajes en una cola de salida/salida. La cola de "salida" se convierte en la cola de "entrada" para el siguiente componente de la cadena. Bastante básico.

Ahora estoy tratando de arremangarme las mangas y proporcionar pruebas unitarias para cada componente utilizando el MockEndpoints proporcionado por la API de prueba de Camel. He estado vertiendo sobre los javadocs y los pocos ejemplos en el sitio web de Camel, pero tengo dificultades para conectar todos los puntos.

Me parece que, para cada componente, una parte de mi unidad de pruebas va a querer llevar a cabo las siguientes tres cosas:

• prueba para ver si hay mensajes en espera en un determinado "de entrada "cola de
• Tire esos mensajes hacia abajo y procesarlas
• impulso nuevos mensajes a una 'cola de salida' y verificar que lo hicieron no

que ser Lieve Necesito crear MockEndpoints para cada cola de este modo:

@EndpointInject(uri = "mock:inputQueue") 
protected MockEndpoint intputQueue; 

@EndpointInject(uri = "mock:outputQueue") 
protected MockEndpoint outputQueue; 

Así que ahora, en mis métodos de prueba JUnit, puedo configurar las expectativas e interactuar con estos criterios de valoración:

@Test 
public final void processMethodShouldSendToOutputQueue() 
{ 
    Component comp = new Component(); 
    comp.process(); 

    outputQueue.assertIsSatisfied(); 
} 

estoy simplemente no entender cómo cablear todo correctamente:

• ¿Cómo conecto comp a la inputQueue y outputQueue MockEndpoints?
• Para cada MockEndpoint, ¿cómo configuro las expectativas para que assertIsSatisfied() verifique que un mensaje esté presente dentro de una cola en particular, o que una cola en particular contenga mensajes?

Answer 1

Adam, hay varias formas de hacerlo.

Para componentes POJO, blackbox pruébelos por separado de cualquier contexto/enrutamiento Camel para centrarse en la lógica comercial.

Si desea realizar pruebas de extremo a extremo de las rutas, considere utilizar uno de estos enfoques para validar que cada paso de la ruta se cumpla.

• uso NotifyBuilder para construir expresiones de validación de cambio (un tanto complejos para conseguir su cabeza alrededor)
• uso AdviceWith para cambiar dinámicamente la ruta antes de su ejecución (añadir log/puntos finales Mock, etc.)

Prefiero AdviceWith porque es muy flexible y aprovecha los conocidos MockEndpoints. Para un ejemplo completo de este tema, consulte this unit test

En resumen, se creará una unidad de prueba para inyectar MockEndpoints en su ruta y luego validar contra ellos como de costumbre ...

context.getRouteDefinition("myRouteId").adviceWith(context, new AdviceWithRouteBuilder() { 
    @Override 
    public void configure() throws Exception { 
     // mock all endpoints 
     mockEndpoints(); 
    } 
}); 

getMockEndpoint("mock:direct:start").expectedBodiesReceived("Hello World"); 

template.sendBody("direct:start", "Hello World");