接收 Spring Cloud Stream 應用程式的訊息

使用 Spring Cloud Stream 輸入繫結器接收來自 Pub/Sub 的訊息。

程式碼範例

Java

在試用這個範例之前，請先按照「使用用戶端程式庫的 Pub/Sub 快速入門導覽課程」中的 Java 設定操作說明進行操作。詳情請參閱 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 瀏覽器範例。