com.fr.fs.schedule.cluster

接口 ScheduleClusterProcessor

所有超级接口:

Immutable, Layer, Level

所有已知实现类:

AbstractScheduleClusterProcessor

public interface ScheduleClusterProcessor
extends Immutable

Created by ibm on 2017/7/13.

字段概要

字段

限定符和类型	字段和说明
static int	CURRENT_LEVEL
static java.lang.String	XML_TAG

从接口继承的字段 com.fr.stable.fun.mark.Layer

DEFAULT_LAYER_INDEX

方法概要

方法

限定符和类型	方法和说明
boolean	deleteScheduleAction(java.lang.Class clazz, long id) 从主机中删除数据库中的ACTION
java.lang.Object	getLoadClass(java.lang.Class clazz, long taskId) 从主机获取scheduleTask
ScheduleOutputProvider	getScheduleOutput(java.lang.Class clazz, long taskId) 从主机获取scheduleOutput
void	notifyHostSyncFile(java.lang.String filePath, boolean isCustomPath) 提醒主机同步文件
void	pushMessage(ScheduleTaskProvider scheduleTask, java.lang.String currentUserName, java.lang.String pushMsg) 在主机进行消息推送
java.util.List	queryScheduleFileEntry(java.util.HashMap fvMap) 从主机获取FileEntry
void	recordScheduleError(ScheduleTaskProvider scheduleTask, java.lang.String msg, java.lang.Throwable e, java.lang.String detailMsg, java.lang.String path) 记录定时器的日志（错误级别）
void	recordScheduleInfo(ScheduleTaskProvider scheduleTask, java.lang.String msg, java.lang.String detailMsg, java.lang.String path) 记录调度任务信息
java.lang.Object	saveCRRInMainService(java.lang.String filePath, boolean isCustomPath, java.lang.String fileName, java.lang.String description) 在主机保存一份生成的cpr用作挂载显示
boolean	scheduledDispatchToMember(com.fr.third.org.quartz.JobExecutionContext context) 将定时调度任务分发给子节点处理
boolean	scheduleOutputRecord(java.lang.Object obj) 在主机的finedb中添加或更新记录

从接口继承的方法 com.fr.stable.fun.Level

currentAPILevel

从接口继承的方法 com.fr.stable.fun.mark.Layer

layerIndex

字段详细资料

XML_TAG

static final java.lang.String XML_TAG

另请参阅:

常量字段值

CURRENT_LEVEL

static final int CURRENT_LEVEL

另请参阅:

常量字段值

方法详细资料

scheduledDispatchToMember

boolean scheduledDispatchToMember(com.fr.third.org.quartz.JobExecutionContext context)

将定时调度任务分发给子节点处理

返回:

boolean

getLoadClass

java.lang.Object getLoadClass(java.lang.Class clazz,
                            long taskId)

从主机获取scheduleTask

参数:

taskId - 任务id

返回:

scheduleTask

getScheduleOutput

ScheduleOutputProvider getScheduleOutput(java.lang.Class clazz,
                                       long taskId)

从主机获取scheduleOutput

参数:

taskId - 任务id

返回:

scheduleOutput

queryScheduleFileEntry

java.util.List queryScheduleFileEntry(java.util.HashMap fvMap)

从主机获取FileEntry

参数:

fvMap - 查询参数

返回:

List

scheduleOutputRecord

boolean scheduleOutputRecord(java.lang.Object obj)

在主机的finedb中添加或更新记录

参数:

obj - 保存更新对象

返回:

boolean

deleteScheduleAction

boolean deleteScheduleAction(java.lang.Class clazz,
                           long id)

从主机中删除数据库中的ACTION

参数:

clazz -

id - id标志

返回:

boolean

recordScheduleInfo

void recordScheduleInfo(ScheduleTaskProvider scheduleTask,
                      java.lang.String msg,
                      java.lang.String detailMsg,
                      java.lang.String path)

记录调度任务信息

参数:

scheduleTask - 定时任务

msg - 日志消息

detailMsg - 详细消息

path - 路径

recordScheduleError

void recordScheduleError(ScheduleTaskProvider scheduleTask,
                       java.lang.String msg,
                       java.lang.Throwable e,
                       java.lang.String detailMsg,
                       java.lang.String path)

记录定时器的日志（错误级别）

参数:

scheduleTask - 定时任务

msg - 日志消息

e - 抛错

path - 路径

detailMsg - 详细消息

saveCRRInMainService

java.lang.Object saveCRRInMainService(java.lang.String filePath,
                                    boolean isCustomPath,
                                    java.lang.String fileName,
                                    java.lang.String description)

在主机保存一份生成的cpr用作挂载显示

参数:

filePath - 文件路径

fileName - 文件名

description - 文件描述

返回:

FileEntry

notifyHostSyncFile

void notifyHostSyncFile(java.lang.String filePath,
                      boolean isCustomPath)

提醒主机同步文件

参数:

filePath - 文件路径

isCustomPath - 是否是自定义路径

pushMessage

void pushMessage(ScheduleTaskProvider scheduleTask,
               java.lang.String currentUserName,
               java.lang.String pushMsg)

在主机进行消息推送

参数:

scheduleTask - 调度任务

currentUserName - 当前用户

pushMsg - 消息内容