...
|
...
|
@@ -68,11 +68,11 @@ public abstract class AbstractMqListener implements ApplicationEventPublisherAwa |
|
|
|
|
|
@Override
|
|
|
public void onMessage(Message message, Channel channel) throws Exception {
|
|
|
if (ignoreIncrease) {
|
|
|
logger.warn("be ignoreIncreasing ,please close the flag after successed ");
|
|
|
return;
|
|
|
}
|
|
|
try {
|
|
|
if (ignoreIncrease) {
|
|
|
logger.warn("be ignoreIncreasing ,please close the flag after successed ");
|
|
|
return;
|
|
|
}
|
|
|
rebuildFlagService.waitingRebuildingIndex();
|
|
|
this.doBeforeConsume();
|
|
|
this.doConsume(message);
|
...
|
...
|
|