Необходимо написать тесты (Junit) для проверки того, что сообщения используются или нет при публикации в pubsub. Для этого я использовал концепцию интеграции с пружиной.
Код для получения сообщений из pubsub при публикации.
@ SpringBootApplication
открытый класс MyGcpSubPlanetApplication {
приватный статический финал Log LOGGER = LogFactory.getLog (MyGcpSubPlanetApplication.class);
публичный статический void main (String [] args) {
SpringApplication.run(MyGcpSubPlanetApplication.class, args);
}
@ Public Bean PubSubInboundChannelAdapter messageChannelAdapter (@Qualifier ("myInputChannel") MessageChannel inputChannel, PubSubTemplate pubSubTemplate) {
* 1017)*}
@ Bean public MessageChannel myInputChannel () {
return new DirectChannel();
}
@ ServiceActivator (inputChannel = "myInputChannel")
public void messageReceiver(Строковая полезная нагрузка) {
LOGGER.info("Message arrived! Payload: " + payload);
}
}