diff --git a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java index 3f81170..ee7aafa 100644 --- a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java +++ b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java @@ -39,7 +39,7 @@ public class MessageConsumer { } @RabbitHandler - @RabbitListener(queues = {"websocket.drone.queue"}) + @RabbitListener(queues = {"websocket.drone.queue"}, concurrency = "8") public void receiveDroneMessage(final String message) throws JsonProcessingException { log.info("websocket message : {}", message); GPModel model = objectMapper.readValue(message, GPModel.class);