Last active
September 13, 2018 03:25
-
-
Save danvalencia/6cb0235ec01952bbc54fdc91b106be70 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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(); | |
}; | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment