* method name changes

ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/AbstractEthTask.java

@@ -100,7 +100,7 @@ protected final <S> CompletableFuture<S> executeSubTask(
    */
   protected final <S> CompletableFuture<S> executeWorkerSubTask(
       final EthScheduler scheduler, final Supplier<CompletableFuture<S>> subTask) {
-    return executeSubTask(() -> scheduler.scheduleWorkerTask(subTask));
+    return executeSubTask(() -> scheduler.scheduleSyncWorkerTask(subTask));
   }
 
   public final T result() {

ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/EthScheduler.java

@@ -74,7 +74,8 @@ protected EthScheduler(
     this.txWorkerExecutor = txWorkerExecutor;
   }
 
-  public <T> CompletableFuture<T> scheduleWorkerTask(final Supplier<CompletableFuture<T>> future) {
+  public <T> CompletableFuture<T> scheduleSyncWorkerTask(
+      final Supplier<CompletableFuture<T>> future) {
     final CompletableFuture<T> promise = new CompletableFuture<>();
     final Future<?> workerFuture =
         syncWorkerExecutor.submit(
@@ -100,11 +101,11 @@ public <T> CompletableFuture<T> scheduleWorkerTask(final Supplier<CompletableFut
     return promise;
   }
 
-  public Future<?> scheduleWorkerTask(final Runnable command) {
+  public Future<?> scheduleSyncWorkerTask(final Runnable command) {
     return syncWorkerExecutor.submit(command);
   }
 
-  public Future<?> scheduleTransactionTask(final Runnable command) {
+  public Future<?> scheduleTxWorkerTask(final Runnable command) {
     return txWorkerExecutor.submit(command);
   }
 

ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/BlockPropagationManager.java

@@ -117,7 +117,7 @@ private void onBlockAdded(final BlockAddedEvent blockAddedEvent, final Blockchai
               protocolSchedule, protocolContext, readyForImport, HeaderValidationMode.FULL);
       ethContext
           .getScheduler()
-          .scheduleWorkerTask(importBlocksTask)
+          .scheduleSyncWorkerTask(importBlocksTask)
           .whenComplete(
               (r, t) -> {
                 if (r != null) {
@@ -243,7 +243,7 @@ CompletableFuture<Block> importOrSavePendingBlock(final Block block) {
             protocolSchedule, protocolContext, block, HeaderValidationMode.FULL);
     return ethContext
         .getScheduler()
-        .scheduleWorkerTask(importTask::run)
+        .scheduleSyncWorkerTask(importTask::run)
         .whenComplete(
             (r, t) -> {
               if (t != null) {

ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionSender.java

@@ -42,6 +42,6 @@ public void onTransactionsAdded(final Iterable<Transaction> transactions) {
                     transaction -> transactionTracker.addToPeerSendQueue(peer, transaction)));
     ethContext
         .getScheduler()
-        .scheduleWorkerTask(transactionsMessageSender::sendTransactionsToPeers);
+        .scheduleSyncWorkerTask(transactionsMessageSender::sendTransactionsToPeers);
   }
 }

ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionsMessageHandler.java

@@ -32,7 +32,7 @@ public TransactionsMessageHandler(
   @Override
   public void exec(final EthMessage message) {
     final TransactionsMessage transactionsMessage = TransactionsMessage.readFrom(message.getData());
-    scheduler.scheduleTransactionTask(
+    scheduler.scheduleTxWorkerTask(
         () ->
             transactionsMessageProcessor.processTransactionsMessage(
                 message.getPeer(), transactionsMessage));

ethereum/eth/src/test/java/tech/pegasys/pantheon/ethereum/eth/manager/EthSchedulerTest.java

@@ -46,7 +46,7 @@ public void setup() {
   @Test
   public void scheduleWorkerTask_completesWhenScheduledTaskCompletes() {
     final CompletableFuture<Object> future = new CompletableFuture<>();
-    final CompletableFuture<Object> result = ethScheduler.scheduleWorkerTask(() -> future);
+    final CompletableFuture<Object> result = ethScheduler.scheduleSyncWorkerTask(() -> future);
 
     assertThat(result.isDone()).isFalse();
     future.complete("bla");
@@ -58,7 +58,7 @@ public void scheduleWorkerTask_completesWhenScheduledTaskCompletes() {
   @Test
   public void scheduleWorkerTask_completesWhenScheduledTaskFails() {
     final CompletableFuture<Object> future = new CompletableFuture<>();
-    final CompletableFuture<Object> result = ethScheduler.scheduleWorkerTask(() -> future);
+    final CompletableFuture<Object> result = ethScheduler.scheduleSyncWorkerTask(() -> future);
 
     assertThat(result.isDone()).isFalse();
     future.completeExceptionally(new RuntimeException("whoops"));
@@ -70,7 +70,7 @@ public void scheduleWorkerTask_completesWhenScheduledTaskFails() {
   @Test
   public void scheduleWorkerTask_completesWhenScheduledTaskIsCancelled() {
     final CompletableFuture<Object> future = new CompletableFuture<>();
-    final CompletableFuture<Object> result = ethScheduler.scheduleWorkerTask(() -> future);
+    final CompletableFuture<Object> result = ethScheduler.scheduleSyncWorkerTask(() -> future);
 
     assertThat(result.isDone()).isFalse();
     future.cancel(false);
@@ -82,7 +82,7 @@ public void scheduleWorkerTask_completesWhenScheduledTaskIsCancelled() {
   @Test
   public void scheduleWorkerTask_cancelsScheduledFutureWhenResultIsCancelled() {
     final CompletableFuture<Object> result =
-        ethScheduler.scheduleWorkerTask(() -> new CompletableFuture<>());
+        ethScheduler.scheduleSyncWorkerTask(() -> new CompletableFuture<>());
 
     assertThat(syncWorkerExecutor.getScheduledFutures().size()).isEqualTo(1);
     final Future<?> future = syncWorkerExecutor.getScheduledFutures().get(0);