import org.apache.kafka.clients.consumer.ConsumerRecords;
-//import org.slf4j.Logger;
-//import org.slf4j.LoggerFactory;
+
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
*/
public MemoryQueue() {
fQueue = new HashMap<>();
- fOffsets = new HashMap<String, HashMap<String, Integer>>();
+ fOffsets = new HashMap<>();
}
/**
{
if ( a == null ) return null;
- final TreeSet<String> set = new TreeSet<String> ();
+ final TreeSet<String> set = new TreeSet<>();
for ( int i=0; i<a.length (); i++ )
{
set.add ( a.getString ( i ));
* the size of the time window for request authentication
*/
public DMaaPAuthenticatorImpl(NsaApiDb<K> db, long authTimeWindowMs) {
- fAuthenticators = new LinkedList<DMaaPAuthenticator<K>>();
+ fAuthenticators = new LinkedList<>();
fAuthenticators.add(new DMaaPOriginalUebAuthenticator<K>(db, authTimeWindowMs));
}
* @throws ConfigDbException
*/
public synchronized Set<String> loadAllTransactionObjs() throws ConfigDbException {
- final TreeSet<String> result = new TreeSet<String>();
+ final TreeSet<String> result = new TreeSet<>();
for (ConfigPath cp : fDb.loadChildrenNames(fBasePath)) {
result.add(cp.getName());
}
LOGGER.info("Fetching list of all api keys and returning in a templated form for display.");
Map<String, NsaSimpleApiKey> keyMap = getApiKeyDb(dmaapContext).loadAllKeyRecords();
- LinkedList<JSONObject> keyList = new LinkedList<JSONObject>();
+ LinkedList<JSONObject> keyList = new LinkedList<>();
JSONObject jsonList = new JSONObject();