|
@@ -33,7 +33,7 @@ public class TableStoreBatchInsertConsumer implements ChannelAwareMessageListene
|
|
|
|
|
|
@Override
|
|
|
@SneakyThrows
|
|
|
- @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE,ackMode="auto")
|
|
|
+ @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE)
|
|
|
public void onMessage(Message message, Channel channel){
|
|
|
try {
|
|
|
String messageInfo = new String(message.getBody(), "utf-8");
|