minor code cleanup

Author: paxtonhare

marklogic-data-hub/src/main/java/com/marklogic/hub/deploy/commands/DeployHubServersCommand.java

@@ -66,12 +66,7 @@ protected void deleteResource(final ResourceManager mgr, CommandContext context,
         final String payload = getPayload(f, context);
         try {
             if (isRestartAfterDelete()) {
-                context.getAdminManager().invokeActionRequiringRestart(new ActionRequiringRestart() {
-                    @Override
-                    public boolean execute() {
-                        return mgr.delete(payload).isDeleted();
-                    }
-                });
+                context.getAdminManager().invokeActionRequiringRestart(() -> mgr.delete(payload).isDeleted());
             } else {
                 mgr.delete(payload);
             }

marklogic-data-hub/src/main/java/com/marklogic/hub/flow/RunFlowResponse.java

@@ -1,9 +1,7 @@
 package com.marklogic.hub.flow;
 
-import javax.xml.bind.annotation.XmlRootElement;
 import java.util.List;
 
-@XmlRootElement(name = "runflowResponse")
 public class RunFlowResponse {
     public long totalCount = 0;
     public long errorCount = 0;

marklogic-data-hub/src/main/java/com/marklogic/hub/flow/impl/FlowRunnerImpl.java

@@ -42,7 +42,6 @@ public class FlowRunnerImpl implements FlowRunner {
     private boolean isFinished = false;
     private JobExecution result = null;
 
-
     public FlowRunnerImpl(HubConfig hubConfig) {
         this.hubConfig = hubConfig;
     }

marklogic-data-hub/src/test/java/com/marklogic/hub/EndToEndTestSjsJson.java

@@ -99,14 +99,12 @@ public void runFlows() throws IOException, ParserConfigurationException, SAXExce
         }
 
         JsonNode node = jobDocMgr.read("/jobs/" + jobExecution.getJobId() + ".json").next().getContent(new JacksonHandle()).get();
-        String nodeStr = node.toString();
-        logger.info(nodeStr);
-        Assert.assertEquals(nodeStr, Long.toString(jobExecution.getJobId()), node.get("jobId").asText());
-        Assert.assertEquals(nodeStr, TEST_SIZE, node.get("successfulEvents").asInt());
-        Assert.assertEquals(nodeStr, 0, node.get("failedEvents").asInt());
-        Assert.assertEquals(nodeStr, TEST_SIZE / BATCH_SIZE, node.get("successfulBatches").asInt());
-        Assert.assertEquals(nodeStr, 0, node.get("failedBatches").asInt());
-        Assert.assertEquals(nodeStr, "FINISHED", node.get("status").asText());
+        Assert.assertEquals(Long.toString(jobExecution.getJobId()), node.get("jobId").asText());
+        Assert.assertEquals(TEST_SIZE, node.get("successfulEvents").asInt());
+        Assert.assertEquals(0, node.get("failedEvents").asInt());
+        Assert.assertEquals(TEST_SIZE / BATCH_SIZE, node.get("successfulBatches").asInt());
+        Assert.assertEquals(0, node.get("failedBatches").asInt());
+        Assert.assertEquals("FINISHED", node.get("status").asText());
     }
 
     @Test
@@ -139,7 +137,6 @@ public void runFlowsWithFailures() throws IOException, ParserConfigurationExcept
                 failed.add(itemId);
             });
 
-
         JobExecution jobExecution = flowRunner.run();
 
         flowRunner.awaitCompletion();

marklogic-data-hub/src/test/java/com/marklogic/hub/EndToEndTestXqyJson.java

@@ -166,12 +166,12 @@ public void runFlowsWithFailures() throws IOException, ParserConfigurationExcept
 
         Vector<String> completed = new Vector<>();
         Vector<String> failed = new Vector<>();
+
         flowRunner
             .withFlow(harmonizeFlow)
             .withBatchSize(BATCH_SIZE)
             .withThreadCount(4)
             .onItemComplete((String jobId, String itemId) -> {
-                logger.info(itemId);
                 completed.add(itemId);
             })
             .onItemFailed((String jobId, String itemId) -> {