Browse Source

Rabbitmq - Channel.close 오류 수정

Test
박재우 2 years ago
parent
commit
17ac6d0a88
  1. 2
      src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java

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

@ -34,7 +34,7 @@ public class MessageConsumer {
messageService.insert(model); // GPS 정보 DB 동기화 처리
channel.basicAck(tag, false);
// channel.basicAck(tag, false);
} catch (RuntimeException e) {
channel.basicReject(tag, false);
}

Loading…
Cancel
Save