|
@@ -35,7 +35,7 @@ public class TableStoreBatchInsertConsumer{
|
|
|
|
|
|
@RabbitHandler
|
|
|
@SneakyThrows
|
|
|
- @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE,ackMode = "AUTO",concurrency = "2-10")
|
|
|
+ @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE,ackMode = "AUTO",concurrency = "10-50")
|
|
|
public void onMessage(Message message){
|
|
|
try {
|
|
|
String messageInfo = new String(message.getBody(), "utf-8");
|