Code improvement

Author: ardizioa

src/main/java/com/aardizio/SpringReactiveApplication.java

@@ -18,7 +18,7 @@ public class SpringReactiveApplication implements ApplicationListener<Applicatio
 
 @Qualifier("simpleConsumer")
 @Autowired
-private KafkaReceiver<String,String> receiver;
+private KafkaReceiver<String,String> receiver; 
 
 
 public static void main(String[] args) {

src/main/java/com/aardizio/resource/HotelController.java

@@ -65,19 +65,18 @@ public Mono<Hotels> delete(@PathVariable String id) {
 tracer.currentSpan().tag("hotelid", hotel.getId());
 LOGGER.info("creating a journal 1");
 
-ProducerRecord<String,String> record = new ProducerRecord<String,String>("prova", null, hotel.getId(), hotel.toString());
-Mono<SenderRecord<String,String,String>> mono = Mono.just(SenderRecord.create(record, null));
-
-return hotelRepo.save(hotel)
-.then()
-.and(hotelSender.send(mono)
-.doOnError(e -> LOGGER.error(e.toString()))
-.doOnNext(m -> LOGGER.info("Produced event : {}" , m.toString())))
-.map(v -> hotel)
-.doOnError(e -> LOGGER.error("Error during hotel creation {}" , e));
+return hotelRepo.save(hotel)
+ .flatMapMany(h -> {
+ ProducerRecord<String,String> record = new ProducerRecord<String,String>("prova", null, hotel.getId(), hotel.toString());
+ Mono<SenderRecord<String,String,String>> mono = Mono.just(SenderRecord.create(record, null));
+ return hotelSender.send(mono);
+ })
+.collectList()
+	.flatMap(m -> Mono.just(hotel));
 
 }
 
+
 @GetMapping(value = "/hotels/{uuid}", produces = { MediaType.APPLICATION_JSON_VALUE }, consumes = {
 MediaType.APPLICATION_JSON_VALUE })
 public Mono<Hotels> search(@PathVariable String uuid) {

src/main/resources/application.properties

@@ -12,12 +12,12 @@ spring.data.cassandra.retry-policy=com.datastax.driver.core.policies.DefaultRetr
 
 
 # APACHE KAFKA (KafkaProperties)
-spring.kafka.bootstrap-servers=localhost:9092
+spring.kafka.bootstrap-servers=10.115.137.229:9092
 
 #Distributed tracing
 spring.sleuth.web.additionalSkipPattern=
 spring.application.name=Spring-Reactive
-logging.level.org.springframework.cloud.sleuth=DEBUG
+logging.level.org.springframework.cloud.sleuth=INFO
 spring.sleuth.baggage-keys=brequestId,bgroupId
 propagation-keys=requestId,groupId
 management.endpoints.web.exposure.include=jolokia
@@ -40,8 +40,8 @@ spring.devtools.remote.debug.local-port=8787
 #logging.file=server.log
 logging.level.org.springframework=INFO
 logging.level.org.springframework.data.mongodb.core.MongoTemplate=INFO
-logging.level.org.hibernate.SQL=TRACE
-logging.level.org.hibernate.type=TRACE
+logging.level.org.hibernate.SQL=INFO
+logging.level.org.hibernate.type=INFO
 logging.level.org.hibernate.type.descriptor.sql.BasicBinder=TRACE
 # Settings query logger normal to trace you will see also the bind parameters
 logging.level.com.datastax.driver.core.QueryLogger.NORMAL=TRACE
@@ -50,7 +50,4 @@ logging.level.com.datastax.driver.core.QueryLogger.ERROR=TRACE
 # Appender pattern for output to the console. Only supported with the default logback setup.
 # Appender pattern for output to the console. Only supported with the default logback setup.
 logging.pattern.file=%d{dd-MM-yyyy HH:mm:ss.SSS},${spring.application.name},${PID:- },[%thread],%-5level,%c{1},%X{X-B3-TraceId:-},%X{X-B3-SpanId:-},%X{X-B3-ParentSpanId:-},%X{X-Span-Name:-},%X{TAGS:-},%X{X-Span-Export:-},%m%n
-logging.pattern.console=%d{dd-MM-yyyy HH:mm:ss.SSS},${spring.application.name},${PID:- },[%thread],%-5level,%c{1},%X{X-B3-TraceId:-},%X{X-B3-SpanId:-},%X{X-B3-ParentSpanId:-},%X{X-Span-Name:-},%X{TAGS:-},%X{X-Span-Export:-},%m%n
-
-
-debug=true
+logging.pattern.console=%d{dd-MM-yyyy HH:mm:ss.SSS},${spring.application.name},${PID:- },[%thread],%-5level,%c{1},%X{X-B3-TraceId:-},%X{X-B3-SpanId:-},%X{X-B3-ParentSpanId:-},%X{X-Span-Name:-},%X{TAGS:-},%X{X-Span-Export:-},%m%n