У меня есть следующий класс, который содержит два метода: один для получения общего количества сообщений из очереди, а второй - для обработки сообщений.
@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
метод?