...
|
...
|
@@ -53,7 +53,7 @@ public abstract class AbstractMqListener implements ApplicationEventPublisherAwa |
|
|
* @param message
|
|
|
* @throws Exception
|
|
|
*/
|
|
|
public void onMessage(Message message) throws Exception {
|
|
|
public void handleMessage(Message message) throws Exception {
|
|
|
if (ignoreIncrease) {
|
|
|
logger.warn("be ignoreIncreasing ,please close the flag after successed ");
|
|
|
return;
|
...
|
...
|
|