changes

Author: prasath116

reactive-micro-service/employee-service/src/main/java/com/prs/services/EmployeeApplication.java

@@ -8,6 +8,7 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.annotation.Bean;
 import org.springframework.core.io.ClassPathResource;
 import org.springframework.data.r2dbc.connectionfactory.init.ConnectionFactoryInitializer;
 import org.springframework.data.r2dbc.connectionfactory.init.ResourceDatabasePopulator;

reactive-micro-service/employee-service/src/main/java/com/prs/services/employee/controller/EmployeeController.java

@@ -5,11 +5,14 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.ResponseStatus;
 import org.springframework.web.bind.annotation.RestController;
 
 import com.prs.services.employee.model.Employee;
@@ -50,6 +53,12 @@ public Flux<Employee> findAll() {
 return service.findAll();
 }*/
 
+@DeleteMapping("/delete/{id}")
+@ResponseStatus(HttpStatus.NO_CONTENT)
+ public Mono<Void> deleteById(@PathVariable("id") Long id){
+ return service.deleteById(id);
+
+ }
 @GetMapping("/department/{departmentId}")
 public Flux<Employee> findByDepartment(@PathVariable("departmentId") Long departmentId) {
 LOGGER.info("Employee find: departmentId={}", departmentId);

reactive-micro-service/employee-service/src/main/java/com/prs/services/employee/service/EmployeeServiceImpl.java

@@ -48,6 +48,11 @@ public Flux<Employee> findAll() {
 public Mono<Employee> findById(Long id) {
 return repository.findById(id).map(entityToVomapper);
 }
+
+@Override
+public Mono<Void> deleteById(Long id) {
+return repository.deleteById(id);
+}
 
 @Override
 public Flux<Employee> findByCollege(Long collegeId) {

reactive-micro-service/employee-service/src/main/java/com/prs/services/employee/service/IEmployeeService.java

@@ -19,5 +19,7 @@ public interface IEmployeeService {
 
 Flux<Employee> findByDepartment(Long departmentId);
 
+Mono<Void> deleteById(Long id);
+
 
 }

reactive-micro-service/student-service/src/main/java/com/prs/services/student/controller/StudentController.java

@@ -1,9 +1,13 @@
 package com.prs.services.student.controller;
 
+import java.time.Duration;
+import java.time.LocalTime;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -75,4 +79,10 @@ public Flux<Student> findByCollege(@PathVariable("collegeId") Long collegeId) {
 return service.findByCollege(collegeId);
 }
 
+@GetMapping(path = "/stream-flux", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+public Flux<String> streamFlux() {
+ return Flux.interval(Duration.ofSeconds(1)).limitRequest(5)
+ .map(sequence -> "Flux - " + LocalTime.now().toString()).log();
+}
+
 }