Skip to content

Commit

Permalink
lint fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
nwoodward committed Sep 10, 2024
1 parent 4ad577b commit a2dec7a
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ public void end(Context ctx) throws Exception
long stamp = System.currentTimeMillis();
// first the queueables
Set<TaskQueueEntry> entrySet = new HashSet<TaskQueueEntry>();
if (taskQMap.size() > 0)
if (!taskQMap.isEmpty())
{
List<String> taskList = new ArrayList<String>();
for (String task : taskQMap.keySet())
Expand All @@ -232,7 +232,7 @@ public void end(Context ctx) throws Exception
taskQMap.clear();
}
// now the performables
if (taskPMap.size() > 0)
if (!taskPMap.isEmpty())
{
Curator curator = new Curator();
for (String task : taskPMap.keySet())
Expand All @@ -256,7 +256,7 @@ public void end(Context ctx) throws Exception
}
processDelete(ctx);
}
if (entrySet.size() > 0)
if (!entrySet.isEmpty())
{
taskQueue.enqueue(queueName, entrySet);
}
Expand Down Expand Up @@ -467,7 +467,7 @@ private void mapId(Map<String, Set<String>> map, List<String> tasks, String id)
private void parseTasks(String propName)
{
String taskStr = configurationService.getProperty("replicate.consumer.tasks." + propName);
if (taskStr == null || taskStr.length() == 0)
if (taskStr == null || taskStr.isEmpty())
{
return;
}
Expand Down

0 comments on commit a2dec7a

Please sign in to comment.