Polish chapter 6 code

Author: gregturn

6/part3/build.gradle

@@ -1,8 +1,10 @@
+// tag::spring-cloud[]
 buildscript {
 ext {
 springBootVersion = '2.0.0.BUILD-SNAPSHOT'
 springCloudVersion = 'Finchley.BUILD-SNAPSHOT'
 }
+// end::spring-cloud[]
 repositories {
 mavenCentral()
 maven { url "https://repo.spring.io/snapshot" }
@@ -54,15 +56,19 @@ dependencies {
 compile("org.springframework.boot:spring-boot-starter-thymeleaf")
 compile('org.springframework.boot:spring-boot-starter-actuator')
 compile('org.springframework.boot:spring-boot-devtools')
+// tag::scst[]
 compile('org.springframework.cloud:spring-cloud-starter-stream-rabbit')
 compile('org.springframework.cloud:spring-cloud-stream-reactive')
+// end::scst[]
 compile('org.projectlombok:lombok')
 testCompile('org.springframework.boot:spring-boot-starter-test')
 testCompile("io.projectreactor:reactor-test")
 }
 
+// tag::scst-2[]
 dependencyManagement {
 imports {
 mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
 }
 }
+// end::scst-2[]

6/part3/src/main/java/com/greglturnquist/learningspringboot/comments/CommentController.java

@@ -47,8 +47,8 @@ public CommentController(CounterService counterService) {
 this.flux = Flux.<Message<Comment>>create(
 emitter -> this.commentSink = emitter,
 FluxSink.OverflowStrategy.IGNORE)
-.publish()
-.autoConnect();
+.publish()
+.autoConnect();
 }
 
 @PostMapping("/comments")
@@ -65,8 +65,7 @@ public Mono<String> addComment(Mono<Comment> newComment) {
 }
 
 @StreamEmitter
-@Output(Source.OUTPUT)
-public void emit(FluxSender output) {
+public void emit(@Output(Source.OUTPUT) FluxSender output) {
 output.send(this.flux);
 }
 

6/part3/src/main/java/com/greglturnquist/learningspringboot/comments/CommentService.java

@@ -50,9 +50,10 @@ public CommentService(CommentWriterRepository repository,
 // tag::stream-2[]
 @StreamListener
 @Output(Processor.OUTPUT)
-public Flux<Void> save(@Input(Processor.INPUT) Flux<Comment> newComment) {
+public Flux<Void> save(@Input(Processor.INPUT)
+ Flux<Comment> newComments) {
 return repository
-.saveAll(newComment)
+.saveAll(newComments)
 .flatMap(comment -> {
 counterService.increment(
 "comments.total.consumed");

6/part3/src/main/resources/application.yml

@@ -1,8 +1,5 @@
-
+# tag::settings[]
 spring:
- http:
- multipart:
- max-file-size: 10MB
  cloud:
  stream:
  bindings:
@@ -12,11 +9,12 @@ spring:
  output:
  destination: learning-spring-boot-comments
  group: learning-spring-boot
+# end::settings[]
+# tag::logs[]
 logging:
  level:
  org:
- rabbitmq: TRACE
  springframework:
- amqp: TRACE
- cloud: TRACE
- integration: TRACE
+ cloud: DEBUG
+ integration: DEBUG
+# end::logs[]