|
|
@ -33,7 +33,7 @@ public class MessageConsumer { |
|
|
|
GPModel model = objectMapper.readValue(message, GPModel.class); |
|
|
|
GPModel model = objectMapper.readValue(message, GPModel.class); |
|
|
|
|
|
|
|
|
|
|
|
messageService.insert(model); // GPS 정보 DB 동기화 처리
|
|
|
|
messageService.insert(model); // GPS 정보 DB 동기화 처리
|
|
|
|
|
|
|
|
channel.queueDeclare(message, true, false, false, null); |
|
|
|
channel.basicAck(tag, false); |
|
|
|
channel.basicAck(tag, false); |
|
|
|
} catch (RuntimeException e) { |
|
|
|
} catch (RuntimeException e) { |
|
|
|
channel.basicReject(tag, false); |
|
|
|
channel.basicReject(tag, false); |
|
|
|