001
014
015 package com.liferay.portal.search.background.task;
016
017 import com.liferay.portal.kernel.backgroundtask.BackgroundTaskConstants;
018 import com.liferay.portal.kernel.backgroundtask.BackgroundTaskStatusMessageSender;
019 import com.liferay.portal.kernel.backgroundtask.BackgroundTaskThreadLocal;
020 import com.liferay.portal.kernel.messaging.Message;
021 import com.liferay.portal.kernel.search.background.task.ReindexBackgroundTaskConstants;
022 import com.liferay.portal.kernel.search.background.task.ReindexStatusMessageSender;
023
024
027 public class ReindexStatusMessageSenderImpl
028 implements ReindexStatusMessageSender {
029
030 @Override
031 public void sendStatusMessage(String className, long count, long total) {
032 Message message = new Message();
033
034 message.put(
035 BackgroundTaskConstants.BACKGROUND_TASK_ID,
036 BackgroundTaskThreadLocal.getBackgroundTaskId());
037 message.put(ReindexBackgroundTaskConstants.CLASS_NAME, className);
038 message.put(ReindexBackgroundTaskConstants.COUNT, count);
039 message.put(ReindexBackgroundTaskConstants.TOTAL, total);
040
041 _backgroundTaskStatusMessageSender.sendBackgroundTaskStatusMessage(
042 message);
043 }
044
045 @Override
046 public void sendStatusMessage(
047 String phase, long companyId, long[] companyIds) {
048
049 Message message = new Message();
050
051 message.put(
052 BackgroundTaskConstants.BACKGROUND_TASK_ID,
053 BackgroundTaskThreadLocal.getBackgroundTaskId());
054 message.put(ReindexBackgroundTaskConstants.COMPANY_ID, companyId);
055 message.put(ReindexBackgroundTaskConstants.COMPANY_IDS, companyIds);
056 message.put(ReindexBackgroundTaskConstants.PHASE, phase);
057
058 _backgroundTaskStatusMessageSender.sendBackgroundTaskStatusMessage(
059 message);
060 }
061
062 public void setBackgroundTaskStatusMessageSender(
063 BackgroundTaskStatusMessageSender backgroundTaskStatusMessageSender) {
064
065 _backgroundTaskStatusMessageSender = backgroundTaskStatusMessageSender;
066 }
067
068 private BackgroundTaskStatusMessageSender
069 _backgroundTaskStatusMessageSender;
070
071 }