作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中me.hao0.antares.common.util.ZkPaths.pathOfJobInstance()
方法的一些代码示例,展示了ZkPaths.pathOfJobInstance()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkPaths.pathOfJobInstance()
方法的具体详情如下:
包路径:me.hao0.antares.common.util.ZkPaths
类名称:ZkPaths
方法名:pathOfJobInstance
[英]Get the path of the job instance
[中]获取作业实例的路径
代码示例来源:origin: ihaolin/antares
/**
* Delete the job instance from zk
* @param appName the app name
* @param jobClass the job class
* @param jobInstanceId the job instance id
* @return return true if finished the job instance, or false
*/
public Boolean deleteJobInstance(final String appName, final String jobClass, final Long jobInstanceId){
// delete the job instance
String jobInstanceNode = ZkPaths.pathOfJobInstance(appName, jobClass, jobInstanceId);
zk.client().deleteIfExists(jobInstanceNode);
return Boolean.TRUE;
}
代码示例来源:origin: ihaolin/antares
/**
* Trigger the job instance
* @param appName the app name
* @param jobClass the job class
* @param instance the instance
*/
public void triggerJobInstance(String appName, String jobClass, JobInstance instance) {
String jobInstancePath = ZkPaths.pathOfJobInstance(appName, jobClass, instance.getId());
zk.client().create(jobInstancePath, instance.getStatus());
}
代码示例来源:origin: ihaolin/antares
protected void checkInvalidInstance(Long instanceId, ZkJob zkJob, ShardOperateRespCode code) {
if (code != null){
if (ShardOperateRespCode.needCleanJobInstance(code)){
// clean the dirty zk job instance
String jobInstancePath = ZkPaths.pathOfJobInstance(client.getAppName(), zkJob.getJobClass(), instanceId);
client.getZk().deleteIfExists(jobInstancePath);
}
}
}
代码示例来源:origin: ihaolin/antares
String jobInstanceNode = ZkPaths.pathOfJobInstance(appName, jobClass, jobInstanceId);
我是一名优秀的程序员,十分优秀!