review comments

Author: sureshanaparti

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

@@ -1403,8 +1403,13 @@ private void publishOnEventBus(AsyncJob job, String jobEvent) {
             _eventBusPublisher.submit(new ManagedContextRunnable() {
                 @Override
                 protected void runInContext() {
-                    _messageBus.publish(null, AsyncJob.Topics.JOB_EVENT_PUBLISH, PublishScope.LOCAL,
-                        new Pair<AsyncJob, String>(job, 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);
+                    }
                 }
             });
         } catch (RejectedExecutionException e) {