spring-cloud-gcp-pubsub-example-PubSubPublisher.java

public abstract class PubSubPublisher {

    private static final Logger LOGGER = LoggerFactory.getLogger(PubSubPublisher.class);

    private final PubSubTemplate pubSubTemplate;

    protected PubSubPublisher(PubSubTemplate pubSubTemplate) {
        this.pubSubTemplate = pubSubTemplate;
    }

    protected abstract String topic();

    public void publish(String message) {
        LOGGER.info("Publishing to topic [{}]. Message: [{}]", topic(), message);
        pubSubTemplate.publish(topic(), message);
    }

}