Unit-test auf rabbitMQ

Ich habe eine Anwendung veröffentlicht, die Veranstaltung zu RabbitMQ und einem Verbraucher verbraucht der Veranstaltung. Meine Frage ist gibt es eine Möglichkeit zum schreiben eines unit-Tests testen die Funktionalität der Verbraucher.

Nur zum hinzufügen dieser, der Verbraucher arbeitet mehr in einer hierarchischen Struktur ich.e, wenn eine order event ist gebucht, der Unteraufträge in der es extrahiert und Bucht den entsprechenden Ereignissen, die an eine Warteschlange, wenn die Unteraufträge erhalten, verbraucht die lineItems in jeder auch geschrieben, um eine Warteschlange und schließlich die details für die einzelnen lineItem würde gebucht werden.

InformationsquelleAutor Ayodeji | 2014-01-03
  1. 3

    Sieht es aus wie der Weg zu einer easy-to-use-Lösung für die Prüfung von RabbitMQ-bezogene Bildung wird noch immer viel zu erreichen.

    Sehen diese Diskussion und diese Diskussion vom SpringFramework forum. Sie sind entweder mit Mockito (unit-tests) oder eine echte RabbitMQ-Instanz (integration tests) für eigene Tests.

    Finden Sie auch unter diese Beitrag, wo der Autor verwendet eine echte RabbitMQ byt mit einigen Einrichtungen, die mehr 'test-freundlich' Aufgabe. Aber jetzt, die Lösung gilt nur für MAC-user!

    InformationsquelleAutor Younes
  2. 1

    Sich auf die Vorherige Antwort, hier ist eine sehr schnelle Implementierung der unit-test-route (mit Mockito). Der Ausgangspunkt ist eine RabbitMQ eigenen tutorials für java.

    Receiver-Klasse (message-handler)

    public class LocalConsumer extends DefaultConsumer {

    private Channel channel;
    private Logger log;

    //manual dependency injection
    public LocalConsumer(Channel channel, Logger logger) {
        super(channel);
        this.log = logger;
    }

    @Override
    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
            throws IOException {
        String message = new String(body, "UTF-8");
        //insert here whatever logic is needed, using whatever service you injected - in this case it is a simple logger.
        log.print(" [x] Received and processed '" + message + "'");
    }
}

    Test-Klasse

    public class LocalConsumerTest {

    Logger mockLogger = mock(Logger.class);
    Channel mockChannel = mock(Channel.class);
    String mockConsumerTag = "mockConsumerTag";

    LocalConsumer _sut = new LocalConsumer(mockChannel, mockLogger);

    @Test
    public void shouldPrintOutTheMessage () throws java.io.IOException {
        //arrange
        String message = "Test";
        //act
        _sut.handleDelivery(mockConsumerTag, null, new AMQP.BasicProperties(), message.getBytes() );
        //assert
        String expected = " [x] Received and processed '" + message + "'";
        verify(mockLogger).print(eq(expected));
    }
}

    Verbraucher

        //...
    //this is where you inject the system you'll mock in the tests.
    Consumer consumer = new LocalConsumer(channel, _log);
    boolean autoAck = false;
    channel.basicConsume(queueName, autoAck, consumer);
    //...
    InformationsquelleAutor Andrea C
Schreibe einen Kommentar