Commit 2d38f635 authored by Noel Alonso's avatar Noel Alonso
Browse files

Elimina la inserción de vessels en el controlador

parent 3222909a

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

+1 −7
Original line number Diff line number Diff line
@@ -16,21 +16,15 @@ public class VesselTrackingController extends CommandGeoController<VesselTrackin 


	VesselTrackingCommandService service;



	// VesselCommandService vesselService;



	@Autowired

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

	public VesselTrackingController(VesselTrackingCommandService service) {

		super(service);

		this.service = service;

		// 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 track para el barco: " + dto.getMmsi() + " date: " + dto.getTstamp());

		service.create(dto);

	}