Merge pull request #6 from wkennedy/dev

Dev

Author: wkennedy

pubsubly-service/src/main/java/com/github/wkennedy/pubsubly/config/WebConfig.java

@@ -11,10 +11,17 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.hateoas.client.LinkDiscoverer;
+import org.springframework.hateoas.client.LinkDiscoverers;
+import org.springframework.hateoas.mediatype.collectionjson.CollectionJsonLinkDiscoverer;
+import org.springframework.plugin.core.SimplePluginRegistry;
 import org.springframework.web.servlet.config.annotation.CorsRegistry;
 import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
+import java.util.ArrayList;
+import java.util.List;
+
 @Configuration
 public class WebConfig implements WebMvcConfigurer {
 
@@ -25,6 +32,13 @@ public void configureJackson(ObjectMapper jackson2ObjectMapper) {
         jackson2ObjectMapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY);
     }
 
+    @Bean
+    public LinkDiscoverers discoverers() {
+        List<LinkDiscoverer> plugins = new ArrayList<>();
+        plugins.add(new CollectionJsonLinkDiscoverer());
+        return new LinkDiscoverers(SimplePluginRegistry.create(plugins));
+    }
+
     @Override
     public void addCorsMappings(CorsRegistry registry) {
         registry.addMapping("/**");

pubsubly-service/src/main/java/com/github/wkennedy/pubsubly/demo/DemoConfig.java

@@ -14,7 +14,7 @@ public class DemoConfig {
     private static final String KAFKA_ORDER_TOPIC = "DEMO-KAFKA_ORDER_TOPIC";
     private static final String KAFKA_USER_TOPIC = "DEMO-KAFKA_USER_TOPIC";
     private static final String REDIS_TOPIC = "REDIS-USER-SESSION";
-    private static final String EXTERNAL_TOPIC = "EXTERNAL_TOPIC";
+    private static final String EXTERNAL_TOPIC = "DEMO-EXTERNAL_TOPIC";
 
     @Bean
     public NewTopic topic1() {

pubsubly-service/src/main/java/com/github/wkennedy/pubsubly/demo/DemoService.java

@@ -57,7 +57,7 @@ public class DemoService {
     private static final String KAFKA_BID_TOPIC = "DEMO-KAFKA_BID_TOPIC";
     private static final String KAFKA_ORDER_TOPIC = "DEMO-KAFKA_ORDER_TOPIC";
     private static final String KAFKA_USER_TOPIC = "DEMO-KAFKA_USER_TOPIC";
-    private static final String EXTERNAL_TOPIC = "EXTERNAL_TOPIC";
+    private static final String EXTERNAL_TOPIC = "DEMO-EXTERNAL_TOPIC";
     private static final String REDIS_TOPIC = "REDIS-USER-SESSION";
 
     private final StringRedisTemplate stringRedisTemplate;

pubsubly-service/src/main/java/com/github/wkennedy/pubsubly/demo/LocalDemoConfig.java

@@ -11,7 +11,7 @@ public class LocalDemoConfig {
     private static final String KAFKA_BID_TOPIC = "DEMO-KAFKA_BID_TOPIC";
     private static final String KAFKA_ORDER_TOPIC = "DEMO-KAFKA_ORDER_TOPIC";
     private static final String KAFKA_USER_TOPIC = "DEMO-KAFKA_USER_TOPIC";
-    private static final String EXTERNAL_TOPIC = "EXTERNAL_TOPIC";
+    private static final String EXTERNAL_TOPIC = "DEMO-EXTERNAL_TOPIC";
 
     @Bean
     public NewTopic topic1() {

pubsubly-service/src/main/java/com/github/wkennedy/pubsubly/demo/LocalDemoService.java

@@ -33,7 +33,7 @@ public class LocalDemoService {
     private static final String KAFKA_BID_TOPIC = "DEMO-KAFKA_BID_TOPIC";
     private static final String KAFKA_ORDER_TOPIC = "DEMO-KAFKA_ORDER_TOPIC";
     private static final String KAFKA_USER_TOPIC = "DEMO-KAFKA_USER_TOPIC";
-    private static final String EXTERNAL_TOPIC = "EXTERNAL_TOPIC";
+    private static final String EXTERNAL_TOPIC = "DEMO-EXTERNAL_TOPIC";
 
 
     private KafkaProperties kafkaProperties;