Extract common task listener notification code

Author: cpettitt-linkedin

src/com/linkedin/parseq/BaseTask.java

@@ -460,14 +460,7 @@ private void purgeListeners(State<T> state)
       TaskListener taskListener;
       while ((taskListener = _taskListeners.poll()) != null)
       {
-        try
-        {
-          taskListener.onUpdate(this, trace);
-        }
-        catch (Throwable e)
-        {
-          LOG.warn("Promise listener threw exception. Ignoring and continuing. Listener: " + taskListener, e);
-        }
+        notifyTaskListener(taskListener, trace);
       }
     }
 
@@ -492,18 +485,23 @@ private void notifyTaskListeners(State<T> state)
       final ShallowTrace trace = buildShallowTrace(state);
       for (TaskListener taskListener : _taskListeners)
       {
-        try
-        {
-          taskListener.onUpdate(this, trace);
-        }
-        catch (Throwable e)
-        {
-          LOG.warn("Promise listener threw exception. Ignoring and continuing. Listener: " + taskListener, e);
-        }
+        notifyTaskListener(taskListener, trace);
       }
     }
   }
 
+  private void notifyTaskListener(TaskListener taskListener, ShallowTrace trace)
+  {
+    try
+    {
+      taskListener.onUpdate(this, trace);
+    }
+    catch (Throwable e)
+    {
+      LOG.warn("Task listener threw exception. Ignoring and continuing. Listener: " + taskListener, e);
+    }
+  }
+
   private ShallowTrace buildShallowTrace(State<T> state)
   {
     return state._trace;