Commit 831c10d0 authored by Noel Alonso's avatar Noel Alonso
Browse files

Elimina listener para crear track vía command

parent 5dc64d5f
Loading
Loading
Loading
Loading
+0 −15
Original line number Diff line number Diff line
package es.redmic.vesselscommands.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

@@ -14,21 +12,8 @@ import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;
@RequestMapping(value = "${controller.mapping.vesseltracking}")
public class VesselTrackingController extends CommandGeoController<VesselTrackingDTO> {

	VesselTrackingCommandService service;

	@Value("${vesseltracking-activity-id}")
	protected String activityId;

	@Autowired
	public VesselTrackingController(VesselTrackingCommandService service) {
		super(service);
		this.service = service;
	}

	@KafkaListener(topics = "${broker.topic.realtime.tracking.vessels}")
	public void run(VesselTrackingDTO dto) throws InterruptedException {

		logger.info("Procesando track para el barco: " + dto.getId() + " date: " + dto.getProperties().getDate());
		service.create(dto, activityId);
	}
}