Commit 29d41e15 authored by Noel Alonso's avatar Noel Alonso
Browse files

Elimina componentes de funcionalidades no usadas

parent 3ebb608a

src/main/java/es/redmic/socket/ingest/geodata/area/IngestDataAreaController.java

deleted100644 → 0
+0 −60
Original line number Diff line number Diff line 
package es.redmic.socket.ingest.geodata.area;



/*-

 * #%L

 * socket

 * %%

 * Copyright (C) 2019 REDMIC Project / Server

 * %%

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 * 

 *      http://www.apache.org/licenses/LICENSE-2.0

 * 

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * #L%

 */



import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.messaging.Message;

import org.springframework.messaging.handler.annotation.DestinationVariable;

import org.springframework.messaging.handler.annotation.MessageMapping;

import org.springframework.stereotype.Controller;



import es.redmic.brokerlib.avro.common.MessageWrapper;

import es.redmic.socket.common.controller.BaseSocketController;



@Controller

public class IngestDataAreaController extends BaseSocketController {



	@Value("${broker.topic.task.ingest.area.run}")

	private String RUN_TOPIC;



	@Value("${broker.topic.task.ingest.area.resume}")

	private String RESUME_TOPIC;



	@Autowired

	public IngestDataAreaController() {

	}



	@MessageMapping("${socket.topic.task.ingest.area.run}")

	public void register(Message<byte[]> message) {



		publishToBroker(RUN_TOPIC, getMessageWrapper(message));

	}



	@MessageMapping("${socket.topic.task.ingest.area.resume}")

	public void resume(Message<byte[]> message, @DestinationVariable String taskId) {



		MessageWrapper messageWrapper = getMessageWrapper(message);

		messageWrapper.setActionId(taskId);



		publishToBroker(RESUME_TOPIC, messageWrapper);

	}

}

src/main/java/es/redmic/socket/ingest/geodata/tracking/IngestDataTrackingController.java

deleted100644 → 0
+0 −60
Original line number Diff line number Diff line 
package es.redmic.socket.ingest.geodata.tracking;



/*-

 * #%L

 * socket

 * %%

 * Copyright (C) 2019 REDMIC Project / Server

 * %%

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 * 

 *      http://www.apache.org/licenses/LICENSE-2.0

 * 

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * #L%

 */



import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.messaging.Message;

import org.springframework.messaging.handler.annotation.DestinationVariable;

import org.springframework.messaging.handler.annotation.MessageMapping;

import org.springframework.stereotype.Controller;



import es.redmic.brokerlib.avro.common.MessageWrapper;

import es.redmic.socket.common.controller.BaseSocketController;



@Controller

public class IngestDataTrackingController extends BaseSocketController {



	@Value("${broker.topic.task.ingest.tracking.run}")

	private String RUN_TOPIC;



	@Value("${broker.topic.task.ingest.tracking.resume}")

	private String RESUME_TOPIC;



	@Autowired

	public IngestDataTrackingController() {

	}



	@MessageMapping("${socket.topic.task.ingest.tracking.run}")

	public void register(Message<byte[]> message) {



		publishToBroker(RUN_TOPIC, getMessageWrapper(message));

	}



	@MessageMapping("${socket.topic.task.ingest.tracking.resume}")

	public void resume(Message<byte[]> message, @DestinationVariable String taskId) {



		MessageWrapper messageWrapper = getMessageWrapper(message);

		messageWrapper.setActionId(taskId);



		publishToBroker(RESUME_TOPIC, messageWrapper);

	}

}

src/main/java/es/redmic/socket/ingest/series/objectcollectingseries/IngestDataObjectCollectingSeriesController.java

deleted100644 → 0
+0 −60
Original line number Diff line number Diff line 
package es.redmic.socket.ingest.series.objectcollectingseries;



/*-

 * #%L

 * socket

 * %%

 * Copyright (C) 2019 REDMIC Project / Server

 * %%

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 * 

 *      http://www.apache.org/licenses/LICENSE-2.0

 * 

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * #L%

 */



import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.messaging.Message;

import org.springframework.messaging.handler.annotation.DestinationVariable;

import org.springframework.messaging.handler.annotation.MessageMapping;

import org.springframework.stereotype.Controller;



import es.redmic.brokerlib.avro.common.MessageWrapper;

import es.redmic.socket.common.controller.BaseSocketController;



@Controller

public class IngestDataObjectCollectingSeriesController extends BaseSocketController {



	@Value("${broker.topic.task.ingest.objectcollectingseries.run}")

	private String RUN_TOPIC;



	@Value("${broker.topic.task.ingest.objectcollectingseries.resume}")

	private String RESUME_TOPIC;



	@Autowired

	public IngestDataObjectCollectingSeriesController() {

	}



	@MessageMapping("${socket.topic.task.ingest.objectcollectingseries.run}")

	public void register(Message<byte[]> message) {



		publishToBroker(RUN_TOPIC, getMessageWrapper(message));

	}



	@MessageMapping("${socket.topic.task.ingest.objectcollectingseries.resume}")

	public void resume(Message<byte[]> message, @DestinationVariable String taskId) {



		MessageWrapper messageWrapper = getMessageWrapper(message);

		messageWrapper.setActionId(taskId);



		publishToBroker(RESUME_TOPIC, messageWrapper);

	}

}

src/main/java/es/redmic/socket/ingest/series/timeseries/IngestDataTimeSeriesController.java

deleted100644 → 0
+0 −60
Original line number Diff line number Diff line 
package es.redmic.socket.ingest.series.timeseries;



/*-

 * #%L

 * socket

 * %%

 * Copyright (C) 2019 REDMIC Project / Server

 * %%

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 * 

 *      http://www.apache.org/licenses/LICENSE-2.0

 * 

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * #L%

 */



import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.messaging.Message;

import org.springframework.messaging.handler.annotation.DestinationVariable;

import org.springframework.messaging.handler.annotation.MessageMapping;

import org.springframework.stereotype.Controller;



import es.redmic.brokerlib.avro.common.MessageWrapper;

import es.redmic.socket.common.controller.BaseSocketController;



@Controller

public class IngestDataTimeSeriesController extends BaseSocketController {



	@Value("${broker.topic.task.ingest.timeseries.run}")

	private String RUN_TOPIC;



	@Value("${broker.topic.task.ingest.timeseries.resume}")

	private String RESUME_TOPIC;



	@Autowired

	public IngestDataTimeSeriesController() {

	}



	@MessageMapping("${socket.topic.task.ingest.timeseries.run}")

	public void register(Message<byte[]> message) {



		publishToBroker(RUN_TOPIC, getMessageWrapper(message));

	}



	@MessageMapping("${socket.topic.task.ingest.timeseries.resume}")

	public void resume(Message<byte[]> message, @DestinationVariable String taskId) {



		MessageWrapper messageWrapper = getMessageWrapper(message);

		messageWrapper.setActionId(taskId);



		publishToBroker(RESUME_TOPIC, messageWrapper);

	}

}

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

deleted100644 → 0
+0 −46
Original line number Diff line number Diff line 
package es.redmic.socket.test.integration.ingest.geodata.area;



/*-

 * #%L

 * socket

 * %%

 * Copyright (C) 2019 REDMIC Project / Server

 * %%

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 * 

 *      http://www.apache.org/licenses/LICENSE-2.0

 * 

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 * #L%

 */



import org.springframework.kafka.annotation.KafkaListener;



import es.redmic.brokerlib.avro.common.MessageWrapper;

import es.redmic.socket.test.integration.ingest.common.IngestBaseBrokerListenerTest;



public class IngestDataAreaBrokerListenerTest extends IngestBaseBrokerListenerTest {



	public IngestDataAreaBrokerListenerTest() {

	}



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

	public void run(MessageWrapper 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.debug("received payload='{}'", payload);

		publishToBroker(INGEST_STATUS_TOPIC, payload);

	}

}