diff --git a/server/src/com/cloud/async/AsyncJobManagerImpl.java b/server/src/com/cloud/async/AsyncJobManagerImpl.java index 7951a709ccd..359d47b1aba 100644 --- a/server/src/com/cloud/async/AsyncJobManagerImpl.java +++ b/server/src/com/cloud/async/AsyncJobManagerImpl.java @@ -51,7 +51,6 @@ import org.apache.cloudstack.framework.jobs.impl.AsyncJobJournalVO; import org.apache.cloudstack.framework.jobs.impl.AsyncJobMBeanImpl; import org.apache.cloudstack.framework.jobs.impl.AsyncJobMonitor; import org.apache.cloudstack.framework.jobs.impl.AsyncJobVO; -import org.apache.cloudstack.framework.jobs.impl.JobSerializerHelper; import org.apache.cloudstack.framework.jobs.impl.SyncQueueItem; import org.apache.cloudstack.framework.jobs.impl.SyncQueueItemVO; import org.apache.cloudstack.framework.jobs.impl.SyncQueueManager; @@ -61,6 +60,7 @@ import org.apache.cloudstack.framework.messagebus.MessageDetector; import org.apache.cloudstack.framework.messagebus.PublishScope; import org.apache.cloudstack.messagebus.TopicConstants; +import com.cloud.api.ApiSerializerHelper; import com.cloud.cluster.ClusterManager; import com.cloud.cluster.ClusterManagerListener; import com.cloud.cluster.ManagementServerHostVO; @@ -234,7 +234,7 @@ public class AsyncJobManagerImpl extends ManagerBase implements AsyncJobManager, job.setInstanceId(null); if (resultObject != null) { - job.setResult(JobSerializerHelper.toSerializedString(resultObject)); + job.setResult(ApiSerializerHelper.toSerializedString(resultObject)); } job.setLastUpdated(DateUtil.currentGMTTime()); @@ -281,7 +281,7 @@ public class AsyncJobManagerImpl extends ManagerBase implements AsyncJobManager, job.setProcessStatus(processStatus); if(resultObject != null) { - job.setResult(JobSerializerHelper.toSerializedString(resultObject)); + job.setResult(ApiSerializerHelper.toSerializedString(resultObject)); } job.setLastUpdated(DateUtil.currentGMTTime()); _jobDao.update(jobId, job); @@ -913,7 +913,7 @@ public class AsyncJobManagerImpl extends ManagerBase implements AsyncJobManager, } private static String getSerializedErrorMessage(String errorMessage) { - return JobSerializerHelper.toSerializedString(getResetResultResponse(errorMessage)); + return ApiSerializerHelper.toSerializedString(getResetResultResponse(errorMessage)); } @Override