Commit 4c31cbc9 authored by Noel Alonso's avatar Noel Alonso
Browse files

Comenta propiedades y funcionalidades

parent f0a4ca75

vessels-commands/src/main/java/es/redmic/vesselscommands/controller/VesselTrackingController.java

+5 −6
Original line number Diff line number Diff line
@@ -7,7 +7,6 @@ import org.springframework.web.bind.annotation.RequestMapping; 


import es.redmic.brokerlib.avro.geodata.tracking.vessels.AISTrackingDTO;

import es.redmic.commandslib.controller.CommandGeoController;

import es.redmic.vesselscommands.service.VesselCommandService;

import es.redmic.vesselscommands.service.VesselTrackingCommandService;

import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;
@@ -17,20 +16,20 @@ public class VesselTrackingController extends CommandGeoController<VesselTrackin 


	VesselTrackingCommandService service;



	VesselCommandService vesselService;

	// VesselCommandService vesselService;



	@Autowired

	public VesselTrackingController(VesselTrackingCommandService service, VesselCommandService vesselService) {

	public VesselTrackingController(VesselTrackingCommandService service/* , VesselCommandService vesselService */) {

		super(service);

		this.service = service;

		this.vesselService = vesselService;

		// this.vesselService = vesselService;

	}



	@KafkaListener(topics = "${broker.topic.realtime.tracking.vessels}")

	public void run(AISTrackingDTO dto) throws InterruptedException {



		logger.info("Procesando barco: " + dto.getMmsi());

		vesselService.create(dto);

		// logger.info("Procesando barco: " + dto.getMmsi());

		// vesselService.create(dto);



		logger.info("Procesando track para el barco: " + dto.getMmsi() + " date: " + dto.getTstamp());

		service.create(dto);

vessels-commands/src/main/resources/application.properties

+0 −5
Original line number Diff line number Diff line
@@ -43,11 +43,6 @@ spring.kafka.consumer.value-deserializer=io.confluent.kafka.serializers.KafkaAvr 


spring.kafka.consumer.max-poll-records=50



#spring.kafka.consumer.properties.max.poll.interval.ms=600000



spring.kafka.producer.retries=5

spring.kafka.properties.request.timeout.ms=605000



spring.kafka.consumer.heartbeat-interval.seconds=100

spring.kafka.consumer.properties.session.timeout.ms=300000