PubsubTestApplication.java

package com.example.pubsubtest;

import com.google.cloud.pubsub.v1.MessageReceiver;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.gcp.pubsub.core.PubSubTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@SpringBootApplication
@Configuration
public class PubsubTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(PubsubTestApplication.class, args);
    }

    @Bean
    public CommandLineRunner readPubSubMessages(PubSubTemplate pubSubTemplate) {
        return args -> pubSubTemplate.subscribe("test-topic-subscription", messageReceiver());
    }

    @Bean
    public CommandLineRunner readPubSubMessages2(PubSubTemplate pubSubTemplate) {
        return args -> pubSubTemplate.subscribe("test-2-topic-subscription", messageReceiver2());
    }

    @Bean
    public MessageReceiver messageReceiver() {
        return (message, ackReplyConsumer) -> {
            System.out.println("Pub sub message is: " + message.getData().toStringUtf8());
            ackReplyConsumer.ack();
        };
    }

    @Bean
    public MessageReceiver messageReceiver2() {
        return (message, ackReplyConsumer) -> {
            System.out.println("Pub sub message is: " + message.getData().toStringUtf8());
            ackReplyConsumer.ack();
        };
    }

}