So testen Sie MANUAL ACK im Spring Stream - RabbitMQ

Question

Ich verwende Spring-Cloud-Stream als Wrapper für RabbitMQ.

In meinem Projekt muss ich MANUAL ACK verwenden. Also habe ich passende Konfiguration/Code hinzugefügt und es funktioniert wenn ich die Anwendung einschalte. Nachrichten werden übergeben und ACK wird vom Konsumenten zurück gesendet.

@StreamListener(target = Sink.INPUT) 
    public void foo(@Payload String message, 
        @Header(AmqpHeaders.CHANNEL) Channel channel, 
        @Header(AmqpHeaders.DELIVERY_TAG) Long deliveryTag) throws IOException { 
    service.bar(message); 
    channel.basicAck(deliveryTag, false); 
    } 

Frage ist:

Ich kann den Test für AUTO ACK schreiben, aber, wie es für MANUAL ACK zu schreiben? Ich weiß einfach nicht, wie man@Header(AmqpHeaders.CHANNEL) Channel channelin meinem Test übergibt?

Answer 1

Ok ich glaube, ich habe herausfinden, wie es mit Mockito zu tun:

@RunWith(SpringRunner.class) 
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE) 
public class FooTest { 

    @Autowired 
    private Sink sink; 

    @MockBean 
    private BarService barService; 

    @Test 
    public void hello() throws Exception { 
    //given 
    Channel channel = mock(Channel.class); 
    HashMap<String, Object> attributes = new HashMap<>(); 
    attributes.put(AmqpHeaders.CHANNEL, channel); 
    attributes.put(AmqpHeaders.DELIVERY_TAG, 1); 

    //when 
    sink.input().send(MessageBuilder.createMessage("test-message", new MessageHeaders(attributes))); 

    //then 
    verify(barService).bar("test-message"); 
    verify(channel).basicAck(1, false); 
    } 

} 

Aber vielleicht weiß jemand, ob es möglich ist, ohne den Ansatz Channel in Header zu verspotten?

Answer 2

Für eine Einheit Test Ihrer Listener-Methode, können Sie es einfach direkt anrufen mit der Mock

foo("test-message", channel, 1L); 

Senden einer Nachricht prüft auch die Infrastruktur, die Sie tun wollen könnte, zum Beispiel, wenn Sie sich verlassen auf die Nachrichtenkonvertierung des Frameworks (dh JSON senden und haben einen POJO @Payload Parameter.