yoho-search / yoho-search-consumer · Commits

Go to a project

Authored by hugufei
Commit 81fb8adca6edf5ea1c9d771b31afb4cbe4c301d4 1 parent 2be559db

fix bug

Inline Side-by-side
Showing 1 changed file with 6 additions and 2 deletions
... ... @@ -5,13 +5,16 @@ import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import com.rabbitmq.client.Channel;
import com.yoho.search.consumer.index.increment.bulks.CommonBulkService;
import com.yoho.search.core.es.model.ESBluk;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.core.ChannelAwareMessageListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
... ... @@ -26,7 +29,7 @@ import com.yoho.search.consumer.index.rebuild.RebuildFlagService;
import com.yoho.search.core.es.utils.IgnoreSomeException;
import org.springframework.messaging.handler.annotation.Payload;
public abstract class AbstractMqListener implements ApplicationEventPublisherAware {
public abstract class AbstractMqListener implements ApplicationEventPublisherAware,MessageListener {
private static final Logger INCREASE_PERFORMANCE = LoggerFactory.getLogger("INCREASE_PERFORMANCE");
private static final Logger SEARCH_EVENT_LOG = LoggerFactory.getLogger("SEARCH_EVENT_LOG");
... ... @@ -53,7 +56,8 @@ public abstract class AbstractMqListener implements ApplicationEventPublisherAwa
* @param message
* @throws Exception
*/
public void handleMessage(Message message){
@Override
public void onMessage(Message message){
if (ignoreIncrease) {
logger.warn("be ignoreIncreasing ,please close the flag after successed ");
return;
... ...