Refactor EntityChangedEventPubSubPublisher to use PubsubTemplate inst…

…ead for spring-integration-core component. Removed GooglePubSubConfig.java and PubsubOutboundGateway.java, removed spring-integration-core dependency from pom

pom.xml

@@ -76,12 +76,6 @@
             <artifactId>spring-cloud-gcp-starter-pubsub</artifactId>
             <version>${spring-cloud-gcp.version}</version>
         </dependency>
-
-        <dependency>
-            <groupId>org.springframework.integration</groupId>
-            <artifactId>spring-integration-core</artifactId>
-        </dependency>
-
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-actuator</artifactId>

src/main/java/org/rutebanken/tiamat/changelog/EntityChangedEventPubSubPublisher.java

@@ -15,7 +15,7 @@
 
 package org.rutebanken.tiamat.changelog;
 
-import org.rutebanken.tiamat.config.PubsubOutboundGateway;
+import com.google.cloud.spring.pubsub.core.PubSubTemplate;
 import org.rutebanken.tiamat.model.EntityInVersionStructure;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -29,15 +29,18 @@
 public class EntityChangedEventPubSubPublisher extends EntityChangedEventPublisher implements EntityChangedListener {
 
     @Autowired
-    private PubsubOutboundGateway pubsubOutboundGateway;
+    private PubSubTemplate pubSubTemplate;
+
+    @Value("${changelog.topic.name:ror.tiamat.changelog}")
+    private String pubSubTopic;
 
     @Value("${changelog.gcp.publish.enabled:true}")
     private boolean pubSubPublish;
 
     @Override
     public void onChange(EntityInVersionStructure entity) {
         if (pubSubPublish && isLoggedEntity(entity)) {
-            pubsubOutboundGateway.sendToPubsub(toEntityChangedEvent(entity, false).toString());
+            pubSubTemplate.publish(pubSubTopic,toEntityChangedEvent(entity, false).toString());
         }
 
     }
@@ -46,7 +49,7 @@ public void onChange(EntityInVersionStructure entity) {
     public void onDelete(EntityInVersionStructure entity) {
 
         if (pubSubPublish && isLoggedEntity(entity)) {
-            pubsubOutboundGateway.sendToPubsub(toEntityChangedEvent(entity, true).toString());
+            pubSubTemplate.publish(pubSubTopic,toEntityChangedEvent(entity, true).toString());
         }
     }
 }