Rename mongo repository to reactive mongo repository

martin-tarjanyi · May 6, 2018 · 3efd798 · 3efd798
1 parent 96b3faa
commit 3efd798
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 16 deletions.
diff --git a/src/main/java/com/example/webfluxdemo/WebfluxDemoApplication.java b/src/main/java/com/example/webfluxdemo/WebfluxDemoApplication.java
@@ -1,7 +1,7 @@
 package com.example.webfluxdemo;
 
 import com.example.webfluxdemo.model.Person;
-import com.example.webfluxdemo.repository.MongoRepository;
+import com.example.webfluxdemo.repository.ReactiveMongoRepository;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
@@ -45,19 +45,19 @@ public CommandLineRunner initRedis(ReactiveRedisTemplate<String, String> reactiv
     }
 
     @Bean
-    public CommandLineRunner savePeopleToMongo(MongoRepository mongoRepository)
+    public CommandLineRunner savePeopleToMongo(ReactiveMongoRepository reactiveMongoRepository)
     {
         return args ->
         {
-            mongoRepository.deleteAll().thenMany(mongoRepository.saveAll(Set.of(
+            reactiveMongoRepository.deleteAll().thenMany(reactiveMongoRepository.saveAll(Set.of(
                                            new Person(1, "Jack", 45, "Oklahoma"),
                                            new Person(2, "John", 24, "Chicago"),
                                            new Person(6, "Smith", 11, "London"),
                                            new Person(5, "Rose", 39, "Kuala Lumpur"),
                                            new Person(7, "Alexander", 44, "Amsterdam"),
                                            new Person(3, "Jane", 32, "Brian"),
                                            new Person(4, "Brian", 48, "New York"))))
-                           .subscribe(person -> log.info("Saved person: " + person));
+                                   .subscribe(person -> log.info("Saved person: " + person));
         };
     }
 

diff --git a/src/main/java/com/example/webfluxdemo/controller/PersonController.java b/src/main/java/com/example/webfluxdemo/controller/PersonController.java
@@ -1,7 +1,7 @@
 package com.example.webfluxdemo.controller;
 
 import com.example.webfluxdemo.model.Person;
-import com.example.webfluxdemo.repository.MongoRepository;
+import com.example.webfluxdemo.repository.ReactiveMongoRepository;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.core.ReactiveRedisTemplate;
 import org.springframework.http.HttpStatus;
@@ -22,12 +22,12 @@
 public class PersonController
 {
     private final ReactiveRedisTemplate<String, String> reactiveRedisTemplate;
-    private final MongoRepository mongoRepository;
+    private final ReactiveMongoRepository reactiveMongoRepository;
 
-    public PersonController(ReactiveRedisTemplate<String, String> reactiveRedisTemplate, MongoRepository mongoRepository)
+    public PersonController(ReactiveRedisTemplate<String, String> reactiveRedisTemplate, ReactiveMongoRepository reactiveMongoRepository)
     {
         this.reactiveRedisTemplate = reactiveRedisTemplate;
-        this.mongoRepository = mongoRepository;
+        this.reactiveMongoRepository = reactiveMongoRepository;
     }
 
     @GetMapping(value = "/slow")
@@ -44,14 +44,14 @@ public Flux<Person> getPersonsByStringNumber(@RequestParam Set<String> numbers)
         return Flux.fromIterable(numbers)
                    .flatMap(number -> reactiveRedisTemplate.opsForValue().get(number).doOnNext(log::info))
                    .map(Integer::valueOf)
-                   .flatMap(id -> mongoRepository.findById(id).doOnNext(person -> log.info(person.toString())))
+                   .flatMap(id -> reactiveMongoRepository.findById(id).doOnNext(person -> log.info(person.toString())))
                    .switchIfEmpty(Mono.error(new IllegalArgumentException("Not found person.")));
     }
 
-    @GetMapping(value = "/people-stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    @GetMapping(value = "/people-stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE) // Server Sent Events (SSE)
     public Flux<Person> getAllAsStream()
     {
-        return mongoRepository.findAll().delayElements(Duration.ofMillis(1000));
+        return reactiveMongoRepository.findAll().delayElements(Duration.ofMillis(1000));
     }
 
     @ExceptionHandler(IllegalArgumentException.class)

diff --git a/...bfluxdemo/repository/MongoRepository.java → ...o/repository/ReactiveMongoRepository.java b/...bfluxdemo/repository/MongoRepository.java → ...o/repository/ReactiveMongoRepository.java
@@ -2,9 +2,7 @@
 
 import com.example.webfluxdemo.model.Person;
 import org.springframework.data.repository.reactive.ReactiveCrudRepository;
-import reactor.core.publisher.Mono;
 
-public interface MongoRepository extends ReactiveCrudRepository<Person, Integer>
+public interface ReactiveMongoRepository extends ReactiveCrudRepository<Person, Integer>
 {
-    Mono<Person> findById(int id);
 }
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -1,2 +1,2 @@
-spring.data.mongodb.host=localhost
-spring.redis.host=localhost
+spring.data.mongodb.host=192.168.99.100
+spring.redis.host=192.168.99.100