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