package com.l7tech.server.log;

import com.l7tech.gateway.common.cluster.ClusterNodeInfo;
import com.l7tech.util.Functions.Unary;

class m implements Unary<Boolean, ClusterNodeInfo> {
   final String val$nodeId;

   m(SinkManagerImpl var1, String var2) {
      this.val$nodeId = var2;
   }

   public Boolean call(ClusterNodeInfo var1) {
      return this.val$nodeId.equals(var1.getNodeIdentifier());
   }
}