|
@@ -33,16 +33,13 @@ public class TableStoreBatchInsertConsumer implements ChannelAwareMessageListene
|
|
|
|
|
|
@Override
|
|
|
@SneakyThrows
|
|
|
- @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE)
|
|
|
+ @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE,ackMode="auto")
|
|
|
public void onMessage(Message message, Channel channel){
|
|
|
- long deliveryTag = message.getMessageProperties().getDeliveryTag();
|
|
|
try {
|
|
|
String messageInfo = new String(message.getBody(), "utf-8");
|
|
|
operateTableStore(messageInfo);
|
|
|
} catch (Exception e) {
|
|
|
- log.error("DEMO异常:{}", e);
|
|
|
- }finally {
|
|
|
- channel.basicAck(deliveryTag, false);
|
|
|
+ log.error("保存码到TableStore异常:{}", e);
|
|
|
}
|
|
|
}
|
|
|
|