fMetrics.toJson();
fMetrics.setupCambriaSender();
// add the admin authenticator
- // final String adminSecret = settings.getString ( CambriaConstants.kSetting_AdminSecret, null );
+
final String adminSecret = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kSetting_AdminSecret);
- //adminSecret = "fe3cCompound";
+
if ( adminSecret != null && adminSecret.length () > 0 )
{
try
final NsaApiDb<NsaSimpleApiKey> adminDb = new BaseNsaApiDbImpl<NsaSimpleApiKey> ( new MemConfigDb(), new NsaSimpleApiKeyFactory() );
adminDb.createApiKey ( "admin", adminSecret );
- //nsaSecurityManager.addAuthenticator ( new OriginalUebAuthenticator<NsaSimpleApiKey> ( adminDb, 10*60*1000 ) );
+
fSecurityManager.addAuthenticator ( new DMaaPOriginalUebAuthenticator<NsaSimpleApiKey> ( adminDb, 10*60*1000 ) );
}
}
// setup a backend
- //final String type = settings.getString(CambriaConstants.kBrokerType, CambriaConstants.kBrokerType_Kafka);
+
String type = com.att.ajsc.filemonitor.AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,CambriaConstants.kBrokerType);
if (type==null) type = CambriaConstants.kBrokerType_Kafka;
if (CambriaConstants.kBrokerType_Kafka.equalsIgnoreCase(type)) {