Commit 6247c83f authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia nivel de log al imprimir información

parent 082faed9

src/test/java/es/redmic/socket/test/integration/ingest/data/document/IngestDataDocumentBrokerListenerTest.java

+2 −3
Original line number Diff line number Diff line
@@ -8,20 +8,19 @@ import es.redmic.socket.test.integration.ingest.common.IngestBaseBrokerListenerT 
public class IngestDataDocumentBrokerListenerTest extends IngestBaseBrokerListenerTest {



	public IngestDataDocumentBrokerListenerTest() {

		logger.info("Creando listeners de document ingest para emular task");

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.document.run}")

	public void run(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.document.resume}")

	public void resume(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}

}

src/test/java/es/redmic/socket/test/integration/ingest/geodata/area/IngestDataAreaBrokerListenerTest.java

+2 −3
Original line number Diff line number Diff line
@@ -8,20 +8,19 @@ import es.redmic.socket.test.integration.ingest.common.IngestBaseBrokerListenerT 
public class IngestDataAreaBrokerListenerTest extends IngestBaseBrokerListenerTest {



	public IngestDataAreaBrokerListenerTest() {

		logger.info("Creando listeners de ingest area para emular task");

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.area.run}")

	public void run(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.area.resume}")

	public void resume(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}

}

src/test/java/es/redmic/socket/test/integration/ingest/geodata/tracking/IngestDataTrackingBrokerListenerTest.java

+2 −3
Original line number Diff line number Diff line
@@ -8,20 +8,19 @@ import es.redmic.socket.test.integration.ingest.common.IngestBaseBrokerListenerT 
public class IngestDataTrackingBrokerListenerTest extends IngestBaseBrokerListenerTest {



	public IngestDataTrackingBrokerListenerTest() {

		logger.info("Creando listeners de ingest tracking para emular task");

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.tracking.run}")

	public void run(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.tracking.resume}")

	public void resume(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}

}

src/test/java/es/redmic/socket/test/integration/ingest/series/objectcollectingseries/IngestDataObjectCollectingSeriesBrokerListenerTest.java

+2 −3
Original line number Diff line number Diff line
@@ -8,20 +8,19 @@ import es.redmic.socket.test.integration.ingest.common.IngestBaseBrokerListenerT 
public class IngestDataObjectCollectingSeriesBrokerListenerTest extends IngestBaseBrokerListenerTest {



	public IngestDataObjectCollectingSeriesBrokerListenerTest() {

		logger.info("Creando listeners de ingest objectcollectingseries para emular task");

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.objectcollectingseries.run}")

	public void run(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.objectcollectingseries.resume}")

	public void resume(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}

}

src/test/java/es/redmic/socket/test/integration/ingest/series/timeseries/IngestDataTimeSeriesBrokerListenerTest.java

+2 −3
Original line number Diff line number Diff line
@@ -8,20 +8,19 @@ import es.redmic.socket.test.integration.ingest.common.IngestBaseBrokerListenerT 
public class IngestDataTimeSeriesBrokerListenerTest extends IngestBaseBrokerListenerTest {



	public IngestDataTimeSeriesBrokerListenerTest() {

		logger.info("Creando listeners de ingest timeseries para emular task");

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.timeseries.run}")

	public void run(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}



	@KafkaListener(topics = "${broker.topic.task.ingest.timeseries.resume}")

	public void resume(MessageWrapper payload) {



		logger.info("received payload='{}'", payload);

		logger.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}

}