pubsub消息没有被轮询器和serviceactivator拉出

Question

我一直在尝试让pubsub在spring应用程序中工作。为了启动和运行，我一直在阅读像这样的教程和文档

我可以让东西构建和启动，但如果我通过云控制台向测试订阅发送消息，它永远不会到达。

这是我现在的代码:

@Configuration
@Import({GcpPubSubAutoConfiguration.class})
public class PubSubConfigurator {
@Bean
public GcpProjectIdProvider projectIdProvider(){
return () -> "project-id";
}
@Bean
public CredentialsProvider credentialsProvider(){
return GoogleCredentials::getApplicationDefault;
}
@Bean
public MessageChannel inputMessageChannel() {
return new PublishSubscribeChannel();
}
@Bean
@InboundChannelAdapter(channel = "inputMessageChannel", poller = @Poller(fixedDelay = "5"))
public MessageSource<Object> pubsubAdapter(PubSubTemplate pubSubTemplate) {
PubSubMessageSource messageSource = new PubSubMessageSource(pubSubTemplate,  "tst-sandbox");
messageSource.setAckMode(AckMode.MANUAL);
messageSource.setPayloadType(String.class);
messageSource.setBlockOnPull(false);
messageSource.setMaxFetchSize(10);
//pubSubTemplate.pull("tst-sandbox", 10, true);
return messageSource;
}
// Define what happens to the messages arriving in the message channel.
@ServiceActivator(inputChannel = "inputMessageChannel")
public void messageReceiver(
String payload,
@Header(GcpPubSubHeaders.ORIGINAL_MESSAGE) BasicAcknowledgeablePubsubMessage message) {
System.out.println("Message arrived via an inbound channel adapter from sub-one! Payload: " + payload);
message.ack();
}
}

我的想法是，轮询器注释会启动一个轮询器，每隔一段时间就运行一次，检查消息，并将它们发送给带有服务激活器注释的方法，但显然情况并非如此，因为它从未被击中。

有趣的是，如果我在return messageSource"并检查模板的结果。pull调用消息被返回，所以它似乎不是连接本身的问题。

我在这里错过了什么?教程和文档在这一点上没有多大帮助，因为它们都使用了几乎相同的教程代码，就像上面一样…

我尝试了上述代码的变体，如创建适配器而不是消息源，如下所示:

@Bean
public PubSubInboundChannelAdapter inboundChannelAdapter(
@Qualifier("inputMessageChannel") MessageChannel messageChannel,
PubSubTemplate pubSubTemplate) {
PubSubInboundChannelAdapter adapter =
new PubSubInboundChannelAdapter(pubSubTemplate, "tst-sandbox");
adapter.setOutputChannel(messageChannel);
adapter.setAckMode(AckMode.MANUAL);
adapter.setPayloadType(String.class);
return adapter;
}

无效。欢迎提出任何建议。

Answer 1

从零开始创建一个spring启动项目后发现问题(主项目为normal spring)注意到在调试输出中，它自动启动了服务激活器bean和其他一些事情，比如实际上订阅了主项目中没有做的通道。

快速搜索后，解决方案很简单，必须添加

@EnableIntegration

注释，消息开始传入。