我一直在尝试让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();
}
}

我的想法是poller注解会启动一个poller，让它每隔一段时间运行一次，以检查消息并将它们发送到用serviceactivator注解的方法，但显然不是这样，因为它从未被命中。
有趣的是，如果我在“return messagesource”前面放置一个断点，并检查template.pull调用的结果，那么返回的消息似乎与连接本身无关。
我错过了什么？教程和文档在这一点上并没有什么帮助，因为它们都使用了与上面类似的几乎相同的教程代码。。。
我尝试了上述代码的变体，例如创建适配器而不是messagesource，如下所示：

@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;
}

无济于事。欢迎提出任何建议。