com.fr.fs.schedule.cluster

类 AbstractScheduleClusterProcessor

java.lang.Object

com.fr.fs.schedule.cluster.AbstractScheduleClusterProcessor

所有已实现的接口:

ScheduleClusterProcessor, Level, Immutable, Layer

public abstract class AbstractScheduleClusterProcessor
extends java.lang.Object
implements ScheduleClusterProcessor

Created by ibm on 2017/7/13.

字段概要

从接口继承的字段 com.fr.fs.schedule.cluster.ScheduleClusterProcessor

CURRENT_LEVEL, XML_TAG

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

DEFAULT_LAYER_INDEX

构造器概要

构造器

构造器和说明
AbstractScheduleClusterProcessor()

方法概要

方法

限定符和类型	方法和说明
int	currentAPILevel() 当前接口的API等级,用于判断是否需要升级插件
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
int	layerIndex() 对于不可变接口,这个值越高的,加载的优先级越高,也就是会覆盖掉其他低优先级的使用同样接口的插件
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中添加或更新记录

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

AbstractScheduleClusterProcessor

public AbstractScheduleClusterProcessor()

方法详细资料

currentAPILevel

public int currentAPILevel()

从接口复制的说明: Level

当前接口的API等级,用于判断是否需要升级插件

指定者:

currentAPILevel 在接口中 Level

返回:

API等级

layerIndex

public int layerIndex()

从接口复制的说明: Layer

对于不可变接口,这个值越高的,加载的优先级越高,也就是会覆盖掉其他低优先级的使用同样接口的插件

指定者:

layerIndex 在接口中 Layer

返回:

层级系数

scheduledDispatchToMember

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

从接口复制的说明: ScheduleClusterProcessor

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

指定者:

scheduledDispatchToMember 在接口中 ScheduleClusterProcessor

返回:

boolean

getLoadClass

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

从接口复制的说明: ScheduleClusterProcessor

从主机获取scheduleTask

指定者:

getLoadClass 在接口中 ScheduleClusterProcessor

taskId - 任务id

返回:

scheduleTask

getScheduleOutput

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

从接口复制的说明: ScheduleClusterProcessor

从主机获取scheduleOutput

指定者:

getScheduleOutput 在接口中 ScheduleClusterProcessor

taskId - 任务id

返回:

scheduleOutput

queryScheduleFileEntry

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

从接口复制的说明: ScheduleClusterProcessor

从主机获取FileEntry

指定者:

queryScheduleFileEntry 在接口中 ScheduleClusterProcessor

参数:

fvMap - 查询参数

返回:

List

scheduleOutputRecord

public boolean scheduleOutputRecord(java.lang.Object obj)

从接口复制的说明: ScheduleClusterProcessor

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

指定者:

scheduleOutputRecord 在接口中 ScheduleClusterProcessor

参数:

obj - 保存更新对象

返回:

boolean

deleteScheduleAction

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

从接口复制的说明: ScheduleClusterProcessor

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

指定者:

deleteScheduleAction 在接口中 ScheduleClusterProcessor

id - id标志

返回:

boolean

recordScheduleInfo

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

从接口复制的说明: ScheduleClusterProcessor

记录调度任务信息

指定者:

recordScheduleInfo 在接口中 ScheduleClusterProcessor

参数:

scheduleTask - 定时任务

msg - 日志消息

detailMsg - 详细消息

path - 路径

recordScheduleError

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

从接口复制的说明: ScheduleClusterProcessor

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

指定者:

recordScheduleError 在接口中 ScheduleClusterProcessor

参数:

scheduleTask - 定时任务

msg - 日志消息

e - 抛错

detailMsg - 详细消息

path - 路径

saveCRRInMainService

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

从接口复制的说明: ScheduleClusterProcessor

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

指定者:

saveCRRInMainService 在接口中 ScheduleClusterProcessor

参数:

filePath - 文件路径

fileName - 文件名

description - 文件描述

返回:

FileEntry

notifyHostSyncFile

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

从接口复制的说明: ScheduleClusterProcessor

提醒主机同步文件

指定者:

notifyHostSyncFile 在接口中 ScheduleClusterProcessor

参数:

filePath - 文件路径

isCustomPath - 是否是自定义路径

pushMessage

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

从接口复制的说明: ScheduleClusterProcessor

在主机进行消息推送

指定者:

pushMessage 在接口中 ScheduleClusterProcessor

参数:

scheduleTask - 调度任务

currentUserName - 当前用户

pushMsg - 消息内容