本文整理汇总了Java中org.quartz.SchedulerMetaData类的典型用法代码示例。如果您正苦于以下问题：Java SchedulerMetaData类的具体用法？Java SchedulerMetaData怎么用？Java SchedulerMetaData使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SchedulerMetaData类属于org.quartz包，在下文中一共展示了SchedulerMetaData类的14个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public SchedulerMetaData getMetaData() throws SchedulerException {
try {
RemotableQuartzScheduler sched = getRemoteScheduler();
return new SchedulerMetaData(getSchedulerName(),
getSchedulerInstanceId(), getClass(), true, isStarted(),
isInStandbyMode(), isShutdown(), sched.runningSince(),
sched.numJobsExecuted(), sched.getJobStoreClass(),
sched.supportsPersistence(), sched.isClustered(), sched.getThreadPoolClass(),
sched.getThreadPoolSize(), sched.getVersion());
} catch (RemoteException re) {
throw invalidateHandleCreateException(
"Error communicating with remote scheduler.", re);
}
}
开发者ID:lamsfoundation，项目名称:lams，代码行数:17，代码来源:RemoteScheduler.java
示例2: initialize
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public void initialize() throws SchedulerException {
try {
bind();
} catch (Exception re) {
throw new SchedulerException(
"Unable to bind scheduler to RMI Registry.", re);
}
if (resources.getJMXExport()) {
try {
registerJMX();
} catch (Exception e) {
throw new SchedulerException(
"Unable to register scheduler with MBeanServer.", e);
}
}
getLog().info("Scheduler meta-data: " +
(new SchedulerMetaData(getSchedulerName(),
getSchedulerInstanceId(), getClass(), boundRemotely, runningSince() != null,
isInStandbyMode(), isShutdown(), runningSince(),
numJobsExecuted(), getJobStoreClass(),
supportsPersistence(), isClustered(), getThreadPoolClass(),
getThreadPoolSize(), getVersion())).toString());
}
开发者ID:AsuraTeam，项目名称:asura，代码行数:27，代码来源:QuartzScheduler.java
示例3: properties
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
@Override
public Map<String, ?> properties(RequestContext ctx) throws Exception {
Map<String, Object> result = new HashMap<>();
if (this.scheduler.isStarted()) {
result.put("status", "started");
} else {
result.put("stats", "stopped");
}
result.put("name", this.scheduler.getSchedulerName());
result.put("instance-id", this.scheduler.getSchedulerInstanceId());
SchedulerMetaData metaData = this.scheduler.getMetaData();
result.put("running-since", metaData.getRunningSince());
return result;
}
开发者ID:liveoak-io，项目名称:liveoak，代码行数:17，代码来源:SchedulerResource.java
示例4: getMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public SchedulerMetaData getMetaData() throws SchedulerException {
AttributeList attributeList =
getAttributes(
new String[] {
"SchedulerName",
"SchedulerInstanceId",
"StandbyMode",
"Shutdown",
"JobStoreClassName",
"ThreadPoolClassName",
"ThreadPoolSize",
"Version",
"PerformanceMetrics"
});
try {
return new SchedulerMetaData(
(String)getAttribute(attributeList, 0).getValue(),
(String)getAttribute(attributeList, 1).getValue(),
getClass(), true, false,
(Boolean)getAttribute(attributeList, 2).getValue(),
(Boolean)getAttribute(attributeList, 3).getValue(),
null,
Integer.parseInt(((Map)getAttribute(attributeList, 8).getValue()).get("JobsExecuted").toString()),
Class.forName((String)getAttribute(attributeList, 4).getValue()),
false,
false,
Class.forName((String)getAttribute(attributeList, 5).getValue()),
(Integer)getAttribute(attributeList, 6).getValue(),
(String)getAttribute(attributeList, 7).getValue());
} catch (ClassNotFoundException e) {
throw new SchedulerException(e);
}
}
开发者ID:lamsfoundation，项目名称:lams，代码行数:35，代码来源:RemoteMBeanScheduler.java
示例5: getMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public SchedulerMetaData getMetaData() {
return new SchedulerMetaData(getSchedulerName(),
getSchedulerInstanceId(), getClass(), false, isStarted(),
isInStandbyMode(), isShutdown(), sched.runningSince(),
sched.numJobsExecuted(), sched.getJobStoreClass(),
sched.supportsPersistence(), sched.isClustered(), sched.getThreadPoolClass(),
sched.getThreadPoolSize(), sched.getVersion());
}
开发者ID:lamsfoundation，项目名称:lams，代码行数:10，代码来源:StdScheduler.java
示例6: getMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public SchedulerMetaData getMetaData() throws SchedulerException {
AttributeList attributeList =
getAttributes(
new String[] {
"schedulerName",
"schedulerInstanceId",
"inStandbyMode",
"shutdown",
"jobStoreClass",
"threadPoolClass",
"threadPoolSize",
"version"
});
return new SchedulerMetaData(
(String)attributeList.get(0),
(String)attributeList.get(1),
getClass(), true, isStarted(),
((Boolean)attributeList.get(2)).booleanValue(),
((Boolean)attributeList.get(3)).booleanValue(),
(Date)invoke("runningSince", new Object[] {}, new String[] {}),
((Integer)invoke("numJobsExecuted", new Object[] {}, new String[] {})).intValue(),
(Class)attributeList.get(4),
((Boolean)invoke("supportsPersistence", new Object[] {}, new String[] {})).booleanValue(),
((Boolean)invoke("isClustered", new Object[] {}, new String[] {})).booleanValue(),
(Class)attributeList.get(5),
((Integer)attributeList.get(6)).intValue(),
(String)attributeList.get(7));
}
开发者ID:AsuraTeam，项目名称:asura，代码行数:30，代码来源:RemoteMBeanScheduler.java
示例7: renderStatusMessage
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
@Override
@Guarded(by = STARTED)
public String renderStatusMessage() {
StringBuilder buff = new StringBuilder();
SchedulerMetaData metaData;
try {
metaData = scheduler.getMetaData();
}
catch (SchedulerException e) {
throw new RuntimeException(e);
}
if (metaData.isShutdown()) {
buff.append("Shutdown");
}
else {
if (metaData.getRunningSince() != null) {
buff.append("Started");
}
else {
buff.append("Stopped");
}
if (metaData.isInStandbyMode()) {
buff.append("; Stand-by");
}
}
return buff.toString();
}
开发者ID:sonatype，项目名称:nexus-public，代码行数:30，代码来源:QuartzSchedulerSPI.java
示例8: getSchedulerMetaDataToXml
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public XmlBuilder getSchedulerMetaDataToXml(Scheduler theScheduler) {
XmlBuilder xbRoot = new XmlBuilder("schedulerMetaData");
try {
SchedulerMetaData smd = theScheduler.getMetaData();
xbRoot.addAttribute("schedulerName", smd.getSchedulerName());
xbRoot.addAttribute("schedulerInstanceId", smd.getSchedulerInstanceId().toString());
xbRoot.addAttribute("version", smd.getVersion());
xbRoot.addAttribute("isPaused", (smd.isInStandbyMode() ? "True" : "False"));
xbRoot.addAttribute("isSchedulerRemote", (smd.isSchedulerRemote() ? "True" : "False"));
xbRoot.addAttribute("isShutdown", (smd.isShutdown() ? "True" : "False"));
xbRoot.addAttribute("isStarted", (smd.isStarted() ? "True" : "False"));
xbRoot.addAttribute("jobStoreSupportsPersistence", (smd.jobStoreSupportsPersistence() ? "True" : "False"));
xbRoot.addAttribute("numJobsExecuted", Integer.toString(smd.getNumberOfJobsExecuted()));
try {
Date runningSince = smd.getRunningSince();
xbRoot.addAttribute("runningSince", (null == runningSince ? "unknown" : DateUtils.format(runningSince, DateUtils.FORMAT_GENERICDATETIME)));
} catch (Exception e) {
log.debug(e);
};
xbRoot.addAttribute("jobStoreClass", smd.getJobStoreClass().getName());
xbRoot.addAttribute("schedulerClass", smd.getSchedulerClass().getName());
xbRoot.addAttribute("threadPoolClass", smd.getThreadPoolClass().getName());
xbRoot.addAttribute("threadPoolSize", Integer.toString(smd.getThreadPoolSize()));
} catch (SchedulerException se) {
log.error(se);
}
return xbRoot;
}
开发者ID:ibissource，项目名称:iaf，代码行数:33，代码来源:SchedulerAdapter.java
示例9: getMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public SchedulerMetaData getMetaData() {
try {
return scheduler.getMetaData();
} catch (final SchedulerException e) {
throw new QuartzSchedulerException(e);
}
}
开发者ID:codelibs，项目名称:elasticsearch-quartz，代码行数:8，代码来源:ScheduleService.java
示例10: initialize
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public void initialize() throws SchedulerException {
try {
bind();
} catch (Exception re) {
throw new SchedulerException(
"Unable to bind scheduler to RMI Registry.", re);
}
if (resources.getJMXExport()) {
try {
registerJMX();
} catch (Exception e) {
throw new SchedulerException(
"Unable to register scheduler with MBeanServer.", e);
}
}
// ManagementRESTServiceConfiguration managementRESTServiceConfiguration
// = resources.getManagementRESTServiceConfiguration();
//
// if (managementRESTServiceConfiguration != null &&
// managementRESTServiceConfiguration.isEnabled()) {
// try {
// /**
// * ManagementServer will only be instantiated and started if one
// * isn't already running on the configured port for this class
// * loader space.
// */
// synchronized (QuartzScheduler.class) {
// if
// (!MGMT_SVR_BY_BIND.containsKey(managementRESTServiceConfiguration.getBind()))
// {
// Class<?> managementServerImplClass =
// Class.forName("org.quartz.management.ManagementServerImpl");
// Class<?> managementRESTServiceConfigurationClass[] = new Class[] {
// managementRESTServiceConfiguration.getClass() };
// Constructor<?> managementRESTServiceConfigurationConstructor =
// managementServerImplClass
// .getConstructor(managementRESTServiceConfigurationClass);
// Object arglist[] = new Object[] { managementRESTServiceConfiguration
// };
// ManagementServer embeddedRESTServer = ((ManagementServer)
// managementRESTServiceConfigurationConstructor.newInstance(arglist));
// embeddedRESTServer.start();
// MGMT_SVR_BY_BIND.put(managementRESTServiceConfiguration.getBind(),
// embeddedRESTServer);
// }
// registeredManagementServerBind =
// managementRESTServiceConfiguration.getBind();
// ManagementServer embeddedRESTServer =
// MGMT_SVR_BY_BIND.get(registeredManagementServerBind);
// embeddedRESTServer.register(this);
// }
// } catch (Exception e) {
// throw new
// SchedulerException("Unable to start the scheduler management REST service",
// e);
// }
// }
getLog().info("Scheduler meta-data: " +
(new SchedulerMetaData(getSchedulerName(),
getSchedulerInstanceId(), getClass(), boundRemotely, runningSince() != null,
isInStandbyMode(), isShutdown(), runningSince(),
numJobsExecuted(), getJobStoreClass(),
supportsPersistence(), isClustered(), getThreadPoolClass(),
getThreadPoolSize(), getVersion())).toString());
}
开发者ID:lamsfoundation，项目名称:lams，代码行数:71，代码来源:QuartzScheduler.java
示例11: getMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public SchedulerMetaData getMetaData() throws SchedulerException {
SchedulerMetaData metaData = scheduler.getMetaData();
return metaData;
}
开发者ID:jiwenxing，项目名称:springboot-quartz，代码行数:5，代码来源:ScheduleJobService.java
示例12: getSchedulerMetadata
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public String getSchedulerMetadata() {
String result;
try {
SchedulerMetaData schedulerMetadata = sched.getMetaData();
JSONObject results_obj = new JSONObject();
JSONArray jsonList1 = new JSONArray();
jsonList1.add(schedulerMetadata.getNumberOfJobsExecuted());
jsonList1.add("Reports the number of jobs executed since the scheduler started");
results_obj.put("Number of jobs executed", jsonList1);
JSONArray jsonList2 = new JSONArray();
jsonList2.add(schedulerMetadata.getRunningSince().toString());
jsonList2.add("Reports the date at which the scheduler started running");
results_obj.put("Running since", jsonList2);
JSONArray jsonList3 = new JSONArray();
jsonList3.add(schedulerMetadata.getSchedulerInstanceId());
jsonList3.add("Reports the instance id of the scheduler");
results_obj.put("Scheduler instance id", jsonList3);
JSONArray jsonList4 = new JSONArray();
jsonList4.add(schedulerMetadata.getSchedulerName());
jsonList4.add("Reports the name of the scheduler");
results_obj.put("Scheduler name", jsonList4);
JSONArray jsonList5 = new JSONArray();
jsonList5.add(schedulerMetadata.isInStandbyMode() ? "yes" : "no");
jsonList5.add("Reports whether the scheduler is in standby mode");
results_obj.put("Standby mode", jsonList5);
JSONArray jsonList6 = new JSONArray();
jsonList6.add(schedulerMetadata.isJobStoreClustered() ? "yes" : "no");
jsonList6.add("Reports whether or not the scheduler's JobStore is clustered");
results_obj.put("JobStore Clustered", jsonList6);
JSONArray jsonList7 = new JSONArray();
jsonList7.add(schedulerMetadata.isJobStoreSupportsPersistence() ? "yes" : "no");
jsonList7.add("Reports whether or not the scheduler's JobStore instance supports persistence");
results_obj.put("JobStore supports persistence", jsonList7);
JSONArray jsonList8 = new JSONArray();
jsonList8.add(schedulerMetadata.isSchedulerRemote() ? "yes" : "no");
jsonList8.add("Reports whether the scheduler is being used remotely (via RMI)");
results_obj.put("Remote Scheduler", jsonList8);
JSONArray jsonList9 = new JSONArray();
jsonList9.add(schedulerMetadata.isShutdown() ? "yes" : "no");
jsonList9.add("Reports whether the scheduler has been shutdown");
results_obj.put("Scheduler shutdown", jsonList9);
JSONArray jsonList10 = new JSONArray();
jsonList10.add(schedulerMetadata.isStarted() ? "yes" : "no");
jsonList10.add("Reports whether the scheduler has been started");
results_obj.put("Scheduler started", jsonList10);
result = results_obj.toJSONString();
jsonList1.clear();
jsonList2.clear();
jsonList3.clear();
jsonList4.clear();
jsonList5.clear();
jsonList6.clear();
jsonList7.clear();
jsonList8.clear();
jsonList9.clear();
jsonList10.clear();
} catch (SchedulerException e) {
result = "";
}
return result;
}
开发者ID:disit，项目名称:sce-backend，代码行数:74，代码来源:Main.java
示例13: getMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
public SchedulerMetaData getMetaData() throws SchedulerException {
return scheduler.getMetaData();
}
开发者ID:FoxBPM，项目名称:FoxBPM，代码行数:4，代码来源:FoxbpmScheduler.java
示例14: getSchedulerMetaData
import org.quartz.SchedulerMetaData; //导入依赖的package包/类
private Map<String, Object> getSchedulerMetaData(Scheduler scheduler) throws ApiException {
Map<String, Object> schedulesMap = new HashMap<String, Object>();
try {
SchedulerMetaData schedulerMetaData = scheduler.getMetaData();
schedulesMap.put("name", schedulerMetaData.getSchedulerName());
schedulesMap.put("instanceId", schedulerMetaData.getSchedulerInstanceId().toString());
schedulesMap.put("version", schedulerMetaData.getVersion());
schedulesMap.put("isSchedulerRemote", schedulerMetaData.isSchedulerRemote());
String state = "unknown";
if(schedulerMetaData.isStarted())
state = "started";
if(schedulerMetaData.isInStandbyMode())
state = "paused";
if(schedulerMetaData.isShutdown())
state = "stopped";
schedulesMap.put("state", state);
schedulesMap.put("shutdown", schedulerMetaData.isShutdown());
schedulesMap.put("started", schedulerMetaData.isStarted());
schedulesMap.put("paused", schedulerMetaData.isInStandbyMode());
schedulesMap.put("jobStoreSupportsPersistence", schedulerMetaData.jobStoreSupportsPersistence());
schedulesMap.put("jobsExecuted", schedulerMetaData.getNumberOfJobsExecuted());
long runningSinceInLong = 0;
try {
Date runningSince = schedulerMetaData.getRunningSince();
runningSinceInLong = runningSince.getTime();
} catch (Exception e) {
log.debug(e);
}
schedulesMap.put("runningSince", runningSinceInLong);
schedulesMap.put("jobStoreClass", schedulerMetaData.getJobStoreClass().getName());
schedulesMap.put("schedulerClass", schedulerMetaData.getSchedulerClass().getName());
schedulesMap.put("threadPoolClass", schedulerMetaData.getThreadPoolClass().getName());
schedulesMap.put("threadPoolSize", schedulerMetaData.getThreadPoolSize());
}
catch (SchedulerException se) {
log.error(se);
}
return schedulesMap;
}
开发者ID:ibissource，项目名称:iaf，代码行数:46，代码来源:ShowScheduler.java
注：本文中的org.quartz.SchedulerMetaData类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论