iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor Spring-Reactor samples

Browse Source
This commit is contained in:
pivovarit 2016-12-28 08:25:21 +01:00
parent 06f10646b1
commit c5b67b5620
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
spring-reactor/src/main/java/com/baeldung/controller/NotificationController.java
View File

@ -1,13 +1,10 @@
package com.baeldung.controller; package com.baeldung.controller;
import com.baeldung.doman.NotificationData;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import com.baeldung.doman.NotificationData;
import reactor.bus.Event; import reactor.bus.Event;
import reactor.bus.EventBus; import reactor.bus.EventBus;
@ -17,7 +14,7 @@ public class NotificationController {
@Autowired @Autowired
private EventBus eventBus; private EventBus eventBus;
@RequestMapping(value = "/startNotification/{param}", method = RequestMethod.GET) @GetMapping("/startNotification/{param}")
public void startNotification(@PathVariable("param") String param) { public void startNotification(@PathVariable("param") String param) {
int notificationSize = Integer.parseInt(param); int notificationSize = Integer.parseInt(param);