src/main/java/org/embulk/output/multi/TransactionalPageOutputDelegate.java in embulk-output-multi-0.2.1 vs src/main/java/org/embulk/output/multi/TransactionalPageOutputDelegate.java in embulk-output-multi-0.2.2

@@ -29,11 +29,11 @@
     ) {
         this.source = source;
         this.delegate = delegate;
         this.taskQueue = new LinkedBlockingQueue<>();
         this.executorService = Executors.newSingleThreadExecutor(
-                new ThreadFactoryBuilder().setNameFormat(String.format(THREAD_NAME_FORMAT, source.getPluginCode(), taskIndex)).build()
+                new ThreadFactoryBuilder().setNameFormat(String.format(THREAD_NAME_FORMAT, source.getTag(), taskIndex)).build()
         );
         this.result = executorService.submit(new Worker());
     }
 
     void add(Page page) {
@@ -74,9 +74,13 @@
         } catch (ExecutionException e) {
             throw new PluginExecutionException(source, e.getCause());
         } finally {
             executorService.shutdown();
         }
+    }
+
+    String getTag() {
+        return source.getTag();
     }
 
     private class Worker implements Callable<TaskReport> {
         @Override
         public TaskReport call() throws InterruptedException {