Package fr.ght1pc9kc.testy.beat.messaging

Class MockedReceiver.MockedConsumerBuilder

java.lang.Object

fr.ght1pc9kc.testy.beat.messaging.MockedReceiver.MockedConsumerBuilder

Enclosing class:

MockedReceiver

public static final class MockedReceiver.MockedConsumerBuilder
extends Object

Intermediate builder for mocked consumer.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<com.rabbitmq.client.Delivery>	start()	Start consuming the given number of requests on the given queue.
MockedReceiver.MockedConsumerBuilder	thenRespond(AmqpMessage response)	Define the next respond for a request.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

thenRespond

public MockedReceiver.MockedConsumerBuilder thenRespond(AmqpMessage response)

Define the next respond for a request.

Parameters:

response - Next response to reply for a request.

Returns:

Builder instance.

start

public reactor.core.publisher.Flux<com.rabbitmq.client.Delivery> start()

Start consuming the given number of requests on the given queue.

Returns:

Flux of received requests. This flux is completed when the number of requests is reached.