Тестирование полученного сообщения с помощью Spring Cloud Stream - PullRequest
Новая
       62

Тестирование полученного сообщения с помощью Spring Cloud Stream

0 голосов
/ 02 августа 2020
• 1000 На самом деле я не знаю, правильно ли я его использую. 
@RunWith(SpringRunner.class)
@IntegrationTest
@SpringBootTest
@AutoConfigureStubRunner(
        stubsMode = StubRunnerProperties.StubsMode.LOCAL,
        ids = "br.com.marco.cadeacerva:users:+:stubs:8090")
public class UsersConsumerTest {

    @Autowired
    StubTrigger trigger;

    @Autowired
    @Qualifier("users-in-0")
    MessageChannel inputDestination;

    @Autowired
    MessageCollector messageCollector;

    @Test
    public void shouldConsumeUsersEvents() {
        trigger.trigger("sendUserMessage");
        BlockingQueue<Message<?>> queue = messageCollector.forChannel(inputDestination);
    }
}

Я хотел бы получить доступ к полученному сообщению и проверить полезную нагрузку, но этот подход вызывает исключение ... 

java.lang.IllegalArgumentException: Channel [bean 'users-in-0'] was not bound by class org.springframework.cloud.stream.test.binder.TestSupportBinder

Есть ли способ протестировать эту полезную нагрузку или мне следует использовать другой подход?

...