try {
log.info("node children changed at path: {}", event.getPath());
- //String grpName = new String(curatorFramework.getData().forPath(event.getPath()));
+
List<String> children = curatorFramework.getChildren().forPath(event.getPath());
log.info("found children nodes prodcessing now");
import com.att.dmf.mr.backends.Publisher;
-//import kafka.producer.KeyedMessage;
+
/**
* class used for logging perspective
int kDefault_MaxThreads = -1;
-// String kSetting_TomcatProtocolClass = "tomcat.protocolClass";
+
//String kDefault_TomcatProtocolClass = Http11NioProtocol.class.getName ();
String kSetting_ZkConfigDbServers = "config.zk.servers";
fLog = EELFManager.getInstance().getLogger(this.getClass().getName());
- //( this.getClass().getName () );
+
}
@Override
public class DMaaPResponseBuilder {
- //private static Logger log = Logger.getLogger(DMaaPResponseBuilder.class);
+
private static final EELFLogger log = EELFManager.getInstance().getLogger(DMaaPResponseBuilder.class);
protected static final int kBufferLength = 4096;
private String getSetting ( String settingKey, String defval )
{
- //return fSettings.getString ( settingKey, defval );
+
String strSet = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,settingKey);
if(strSet==null)strSet=defval;
return strSet;