노승철 2 years ago
parent
commit
8e5d4fd632
  1. 2
      src/main/java/com/palnet/process/message/consumer/MessageConsumer.java
  2. 4
      src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java
  3. 4
      src/main/resources/application.yml

2
src/main/java/com/palnet/process/message/consumer/MessageConsumer.java

@ -30,7 +30,7 @@ public class MessageConsumer {
@RabbitHandler
@RabbitListener(queues = {"websocket.drone.queue"})
public void receiveDroneMessage(final String message) throws JsonProcessingException {
log.info("websocket message : {}", message);
log.debug("websocket message : {}", message);
GPModel model = objectMapper.readValue(message, GPModel.class);

4
src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java

@ -14,7 +14,7 @@ import java.util.Objects;
@Component
public class GpHistoryScheduler {
private final int timeLimit = 300; // 5분
private final int timeLimit = 10; // -- 테스트 10초
private final GPHistoryShareContext gpHistoryShareContext;
public GpHistoryScheduler(GPHistoryShareContext gpHistoryShareContext) {
@ -22,7 +22,7 @@ public class GpHistoryScheduler {
}
/* Client 노출 시간 5분 */
@Scheduled(fixedDelay = 1000 * 60 * 5)
@Scheduled(fixedDelay = 1000 * 10)
public void removeHistory() {
Map<String, CtrCntrlModel> allHistory = gpHistoryShareContext.getAllHistory();

4
src/main/resources/application.yml

@ -7,10 +7,6 @@ spring:
port: 5672
username: guest
password: guest
listener:
simple:
max-concurrency: 8
concurrency: 4
server:
port: 8181

Loading…
Cancel
Save