modify the black list
@@ -11,7 +11,6 @@ import org.unidal.lookup.logging.LogEnabled;
import org.unidal.lookup.logging.Logger;
import com.dianping.cat.Cat;
-import com.dianping.cat.CatConstants;
import com.dianping.cat.config.server.BlackListManager;
import com.dianping.cat.message.Message;
import com.dianping.cat.message.MessageProducer;
@@ -32,8 +31,6 @@ public class RealtimeConsumer extends ContainerHolder implements MessageConsumer
private PeriodManager m_periodManager;
- private long m_black = -1;
-
private Logger m_logger;
public static final long MINUTE = 60 * 1000L;
@@ -42,10 +39,6 @@ public class RealtimeConsumer extends ContainerHolder implements MessageConsumer
@Override
public void consume(MessageTree tree) {
- String domain = tree.getDomain();
- String ip = tree.getIpAddress();
-
- if (!m_blackListManager.isBlack(domain, ip)) {
long timestamp = tree.getMessage().getTimestamp();
Period period = m_periodManager.findPeriod(timestamp);
@@ -54,13 +47,6 @@ public class RealtimeConsumer extends ContainerHolder implements MessageConsumer
} else {
m_serverStateManager.addNetworkTimeError(1);
}
- } else {
- m_black++;
-
- if (m_black % CatConstants.SUCCESS_COUNT == 0) {
- Cat.logEvent("Discard", domain);
- }
- }
}
public void doCheckpoint() {
