Как смоделировать метод, который использует моно функцию ядра Reactor - PullRequest
0 голосов
/ 07 января 2020

У меня есть следующий класс, который содержит два метода: один для получения общего количества сообщений из очереди, а второй - для обработки сообщений.

@RestController
public class  JMSController {

    public String process(){

        int totalMessage= getNumberOfMessageInQueue() ;
        // rest of the code

   }


    public int getNumberOfMessageInQueue(String queueName) {

        Mono<Integer> messageCount= Mono.fromCallable( () -> {
             return jmsTemplate.browse(queueName, (session, queueBrowser) ->
                    Collections.list(queueBrowser.getEnumeration()).size()
            );
        }).timeout(Duration.ofSeconds(5L)).subscribeOn(Schedulers.elastic());

        return  messageCount.block();
    }

}

Я пишу контрольный пример Junit для метода process().

Мой вопрос: Как смоделировать getNumberOfMessageInQueue метод?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...