Console
    Start free

    Receive messages in Spring Cloud Stream applications

    Use a Spring Cloud Stream input binder to receive messages from Pub/Sub.

    Code sample

    Java

    Before trying this sample, follow the Java setup instructions in the Pub/Sub quickstart using client libraries . For more information, see the Pub/Sub Java API reference documentation .

    To authenticate to Pub/Sub, set up Application Default Credentials. For more information, see Set up authentication for a local development environment .

      // 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 
 ()); 
  
 }; 
 }

    What's next

    To search and filter code samples for other Google Cloud products, see the Google Cloud sample browser .
    Create a Mobile Website
    View Site in Mobile | Classic
    Share by: