接收 Spring Cloud Stream 应用中的消息

使用 Spring Cloud Stream 输入 Binder 接收来自 Pub/Sub 的消息。

深入探索

如需查看包含此代码示例的详细文档，请参阅以下内容：

• 在 Spring 应用中使用 Pub/Sub

代码示例

Java

在尝试此示例之前，请按照Java Pub/Sub 快速入门： 客户端库。 有关详情，请参阅 Pub/Sub Java API 参考文档。

如需向 Pub/Sub 进行身份验证，请设置应用默认凭据。 如需了解详情，请参阅为本地开发环境设置身份验证。

// Create an input binder to receive messages from `topic-two` using a Consumer bean.
@Bean
public Consumer<Message<String>> receiveMessageFromTopicTwo() {
  return message -> {
    LOGGER.info(
        "Message arrived via an input binder from topic-two! Payload: " + message.getPayload());
  };
}

后续步骤

如需搜索和过滤其他 Google Cloud 产品的代码示例，请参阅 Google Cloud 示例浏览器。