@ -28,8 +28,9 @@ public class MessageConsumer {
}
@RabbitHandler
@RabbitListener(queues = {"websocket.drone.queue"})
@RabbitListener(queues = {"websocket.drone.queue"}, concurrency = "8")
public void receiveDroneMessage(final String message) throws JsonProcessingException {
GPModel model = objectMapper.readValue(message, GPModel.class);
CtrCntrlModel history = this.modelConvert(model);
@ -21,8 +21,8 @@ public class GpHistoryScheduler {
this.gpHistoryShareContext = gpHistoryShareContext;
/* Client 노출 시간 Test 10초 */
@Scheduled(fixedDelay = 1000 * 10)
/* Client 노출 시간 5분 */
@Scheduled(fixedDelay = 10000 * 5)
public void removeHistory() {
Map<String, CtrCntrlModel> allHistory = gpHistoryShareContext.getAllHistory();