review changes

Author: sureshanaparti

framework/jobs/src/main/java/org/apache/cloudstack/framework/jobs/impl/AsyncJobManagerImpl.java

@@ -1403,20 +1403,24 @@ private void publishOnEventBus(AsyncJob job, String jobEvent) {
             _eventBusPublisher.submit(new ManagedContextRunnable() {
                 @Override
                 protected void runInContext() {
-                    try {
-                        _messageBus.publish(null, AsyncJob.Topics.JOB_EVENT_PUBLISH, PublishScope.LOCAL,
-                                new Pair<>(job, jobEvent));
-                    } catch (Throwable t) {
-                        logger.warn("Failed to publish async job event on message bus. jobId={}, jobEvent={}",
-                                job != null ? job.getId() : null, jobEvent, t);
-                    }
+                    publishJobEvent(job, jobEvent);
                 }
             });
         } catch (RejectedExecutionException e) {
             logger.warn("Failed to publish async job event, event bus publisher is shut down", e);
         }
     }
 
+    private void publishJobEvent(AsyncJob job, String jobEvent) {
+        try {
+            _messageBus.publish(null, AsyncJob.Topics.JOB_EVENT_PUBLISH, PublishScope.LOCAL,
+                    new Pair<>(job, jobEvent));
+        } catch (Throwable t) {
+            logger.warn("Failed to publish async job event on message bus. jobId={}, jobEvent={}",
+                    job != null ? job.getId() : null, jobEvent, t);
+        }
+    }
+
     @Override
     public List<AsyncJobVO> findFailureAsyncJobs(String... cmds) {
         return _jobDao.getFailureJobsSinceLastMsStart(getMsid(), cmds);