com.enioka.jqm.model.Queue.getName()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(11.3k)|赞(0)|评价(0)|浏览(65)

本文整理了Java中com.enioka.jqm.model.Queue.getName方法的一些代码示例，展示了Queue.getName的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Queue.getName方法的具体详情如下：
包路径：com.enioka.jqm.model.Queue
类名称：Queue
方法名：getName

Queue.getName介绍

[英]Functional key. Queues are specified by name inside all APIs. Must be unique.
Max length is 50.
[中]功能键。队列是在所有API中按名称指定的。必须是独一无二的。
最大长度为50。

代码示例

代码示例来源：origin: enioka/jqm

@Override
public void stop()
{
  jqmlogger.info("Poller " + queue.getName() + " has received a stop order");
  run = false;
  loop.release();
}

代码示例来源：origin: com.enioka.jqm/jqm-engine

@Override
public void stop()
{
  jqmlogger.info("Poller " + queue.getName() + " has received a stop order");
  run = false;
  loop.release();
}

代码示例来源：origin: com.enioka.jqm/jqm-engine

jqmlogger.info("Waiting for the end of {} jobs on queue {} - timeout is {} ms", actualNbThread, this.queue.getName(),
    timeOutMs);

代码示例来源：origin: enioka/jqm

jqmlogger.info("Waiting for the end of {} jobs on queue {} - timeout is {} ms", actualNbThread, this.queue.getName(),
    timeOutMs);

代码示例来源：origin: com.enioka.jqm/jqm-engine

private void registerMBean()
{
  try
  {
    if (this.engine.loadJmxBeans)
    {
      MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
      name = new ObjectName(
          "com.enioka.jqm:type=Node.Queue,Node=" + this.engine.getNode().getName() + ",name=" + this.queue.getName());
      // Unregister MBean if it already exists. This may happen during frequent DP modifications.
      try
      {
        mbs.getMBeanInfo(name);
        mbs.unregisterMBean(name);
      }
      catch (InstanceNotFoundException e)
      {
        // Nothing to do, this should be the normal case.
      }
      mbs.registerMBean(this, name);
    }
  }
  catch (Exception e)
  {
    throw new JqmInitError("Could not create JMX beans", e);
  }
}

代码示例来源：origin: enioka/jqm

private void registerMBean()
{
  try
  {
    if (this.engine.loadJmxBeans)
    {
      MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
      name = new ObjectName(
          "com.enioka.jqm:type=Node.Queue,Node=" + this.engine.getNode().getName() + ",name=" + this.queue.getName());
      // Unregister MBean if it already exists. This may happen during frequent DP modifications.
      try
      {
        mbs.getMBeanInfo(name);
        mbs.unregisterMBean(name);
      }
      catch (InstanceNotFoundException e)
      {
        // Nothing to do, this should be the normal case.
      }
      mbs.registerMBean(this, name);
    }
  }
  catch (Exception e)
  {
    throw new JqmInitError("Could not create JMX beans", e);
  }
}

代码示例来源：origin: com.enioka.jqm/jqm-xml

private static Element getQueueElement(Queue q, DbConn cnx)
{
  Element queue = new Element("queue");
  Element name = new Element("name");
  name.setText(q.getName());
  Element description = new Element("description");
  description.setText(q.getDescription());
  Element timeToLive = new Element("timeToLive");
  timeToLive.setText(q.getTimeToLive() + "");
  queue.addContent(name);
  queue.addContent(description);
  queue.addContent(timeToLive);
  Element jobs = new Element("jobs");
  queue.addContent(jobs);
  List<JobDef> jds = JobDef.select(cnx, "jd_select_by_queue", q.getId());
  for (JobDef j : jds)
  {
    Element job = new Element("applicationName");
    job.setText(j.getApplicationName());
    jobs.addContent(job);
  }
  return queue;
}

代码示例来源：origin: enioka/jqm

private static Element getQueueElement(Queue q, DbConn cnx)
{
  Element queue = new Element("queue");
  Element name = new Element("name");
  name.setText(q.getName());
  Element description = new Element("description");
  description.setText(q.getDescription());
  Element timeToLive = new Element("timeToLive");
  timeToLive.setText(q.getTimeToLive() + "");
  queue.addContent(name);
  queue.addContent(description);
  queue.addContent(timeToLive);
  Element jobs = new Element("jobs");
  queue.addContent(jobs);
  List<JobDef> jds = JobDef.select(cnx, "jd_select_by_queue", q.getId());
  for (JobDef j : jds)
  {
    Element job = new Element("applicationName");
    job.setText(j.getApplicationName());
    jobs.addContent(job);
  }
  return queue;
}

代码示例来源：origin: com.enioka.jqm/jqm-engine

@Override
public String getJmxBeanName()
{
  return "com.enioka.jqm:type=Node.Queue.JobInstance,Node=" + this.engine.getNode().getName() + ",Queue="
      + this.qp.getQueue().getName() + ",name=" + this.ji.getId();
}

代码示例来源：origin: enioka/jqm

@Override
public String getJmxBeanName()
{
  return "com.enioka.jqm:type=Node.Queue.JobInstance,Node=" + this.engine.getNode().getName() + ",Queue="
      + this.qp.getQueue().getName() + ",name=" + this.ji.getId();
}

代码示例来源：origin: com.enioka.jqm/jqm-engine

void applyDeploymentParameter(DeploymentParameter dp)
{
  this.pollingInterval = dp.getPollingInterval();
  this.maxNbThread = dp.getEnabled() ? dp.getNbThread() : 0;
  this.dpId = dp.getId();
  jqmlogger.info("Engine {}" + " will poll JobInstances on queue {} every {} s", engine.getNode().getName(), queue.getName(),
      pollingInterval / 1000);
  this.threadresourceManagerConfiguration.addParameter("com.enioka.jqm.rm.quantity.quantity", "" + this.maxNbThread);
  this.resourceManagers.get(0).refreshConfiguration(this.threadresourceManagerConfiguration);
}

代码示例来源：origin: enioka/jqm

void applyDeploymentParameter(DeploymentParameter dp)
{
  this.pollingInterval = dp.getPollingInterval();
  this.maxNbThread = dp.getEnabled() ? dp.getNbThread() : 0;
  this.dpId = dp.getId();
  jqmlogger.info("Engine {}" + " will poll JobInstances on queue {} every {} s", engine.getNode().getName(), queue.getName(),
      pollingInterval / 1000);
  this.threadresourceManagerConfiguration.addParameter("com.enioka.jqm.rm.quantity.quantity", "" + this.maxNbThread);
  this.resourceManagers.get(0).refreshConfiguration(this.threadresourceManagerConfiguration);
}

代码示例来源：origin: enioka/jqm

private static com.enioka.jqm.api.Queue getQueue(Queue queue)
{
  com.enioka.jqm.api.Queue q = new com.enioka.jqm.api.Queue();
  q.setDescription(queue.getDescription());
  q.setId(queue.getId());
  q.setName(queue.getName());
  return q;
}

代码示例来源：origin: com.enioka.jqm/jqm-xml

addTextElementToParentElement(jobDefinition, "queue", j.getQueue(cnx).getName());
addTextElementToParentElement(jobDefinition, "description", j.getDescription() == null ? "" : j.getDescription());
addTextElementToParentElement(jobDefinition, "canBeRestarted", j.isCanBeRestarted() ? "true" : "false");

代码示例来源：origin: enioka/jqm

JobDef jd3 = JobDef.select_key(cnx, "DateTime");
Assert.assertEquals("VIPQueue", jd1.getQueue(cnx).getName());
Assert.assertEquals("VIPQueue", jd2.getQueue(cnx).getName());
Assert.assertEquals("NormalQueue", jd3.getQueue(cnx).getName());

代码示例来源：origin: enioka/jqm

addTextElementToParentElement(jobDefinition, "queue", j.getQueue(cnx).getName());
addTextElementToParentElement(jobDefinition, "description", j.getDescription() == null ? "" : j.getDescription());
addTextElementToParentElement(jobDefinition, "canBeRestarted", j.isCanBeRestarted() ? "true" : "false");

代码示例来源：origin: enioka/jqm

@Test
public void testImportQueue() throws Exception
{
  CreationTools.createJobDef(null, true, "com.enioka.jqm.tests.App", null, "jqm-tests/jqm-test-fibo/target/test.jar",
      TestHelpers.qVip, 42, "Fibo", null, "Franquin", "ModuleMachin", "other1", "other2", false, cnx);
  CreationTools.createJobDef(null, true, "App", null, "jqm-tests/jqm-test-geo/target/test.jar", TestHelpers.qVip, 42, "Geo", null,
      "Franquin", "ModuleMachin", "other1", "other2", false, cnx);
  CreationTools.createJobDef(null, true, "App", null, "jqm-tests/jqm-test-datetimemaven/target/test.jar", TestHelpers.qNormal, 42,
      "DateTime", null, "Franquin", "ModuleMachin", "other", "other", false, cnx);
  XmlQueueParser.parse("target/payloads/jqm-test-xml/xmlqueuetest.xml", cnx);
  try
  {
    Queue.select(cnx, "q_select_by_key", "XmlQueue");
    Queue.select(cnx, "q_select_by_key", "XmlQueue2");
    JobDef jd1 = JobDef.select_key(cnx, "Fibo");
    JobDef jd2 = JobDef.select_key(cnx, "Geo");
    JobDef jd3 = JobDef.select_key(cnx, "DateTime");
    Assert.assertEquals("XmlQueue", jd1.getQueue(cnx).getName());
    Assert.assertEquals("XmlQueue", jd2.getQueue(cnx).getName());
    Assert.assertEquals("XmlQueue2", jd3.getQueue(cnx).getName());
  }
  catch (NoResultException e)
  {
    Assert.fail("missing configuration element");
  }
}

代码示例来源：origin: enioka/jqm

JobDef jd3 = JobDef.select_key(cnx, "DateTime");
Assert.assertEquals("VIPQueue", jd1.getQueue(cnx).getName());
Assert.assertEquals("VIPQueue", jd2.getQueue(cnx).getName());
Assert.assertEquals("NormalQueue", jd3.getQueue(cnx).getName());

代码示例来源：origin: com.enioka.jqm/jqm-model

/**
 * Create an History object from a {@link JobInstance}.
 * 
 */
public static void create(DbConn cnx, JobInstance ji, State finalState, Calendar endDate)
{
  JobDef jd = ji.getJD();
  Node n = ji.getNode();
  Queue q = ji.getQ();
  if (endDate == null)
  {
    cnx.runUpdate("history_insert", ji.getId(), jd.getApplication(), jd.getApplicationName(), ji.getAttributionDate(),
        ji.getEmail(), ji.getCreationDate(), ji.getExecutionDate(), jd.isHighlander(), ji.getApplication(), ji.getKeyword1(),
        ji.getKeyword2(), ji.getKeyword3(), ji.getModule(), jd.getKeyword1(), jd.getKeyword2(), jd.getKeyword3(),
        jd.getModule(), n == null ? null : n.getName(), ji.getParentId(), ji.getProgress(), q == null ? null : q.getName(), 0,
        ji.getSessionID(), finalState.toString(), ji.getUserName(), ji.getJdId(), n == null ? null : n.getId(), ji.getQueue(),
        ji.isFromSchedule(), ji.getPriority());
  }
  else
  {
    cnx.runUpdate("history_insert_with_end_date", ji.getId(), jd.getApplication(), jd.getApplicationName(), ji.getAttributionDate(),
        ji.getEmail(), endDate, ji.getCreationDate(), ji.getExecutionDate(), jd.isHighlander(), ji.getApplication(),
        ji.getKeyword1(), ji.getKeyword2(), ji.getKeyword3(), ji.getModule(), jd.getKeyword1(), jd.getKeyword2(),
        jd.getKeyword3(), jd.getModule(), n.getName(), ji.getParentId(), ji.getProgress(), q.getName(), 0, ji.getSessionID(),
        finalState.toString(), ji.getUserName(), ji.getJdId(), ji.getNode().getId(), ji.getQueue(), ji.isFromSchedule(),
        ji.getPriority());
  }
}

代码示例来源：origin: enioka/jqm

/**
 * Create an History object from a {@link JobInstance}.
 *
 */
public static void create(DbConn cnx, JobInstance ji, State finalState, Calendar endDate)
{
  JobDef jd = ji.getJD();
  Node n = ji.getNode();
  Queue q = ji.getQ();
  if (endDate == null)
  {
    cnx.runUpdate("history_insert", ji.getId(), jd.getApplication(), jd.getApplicationName(), ji.getAttributionDate(),
        ji.getEmail(), ji.getCreationDate(), ji.getExecutionDate(), jd.isHighlander(), ji.getApplication(), ji.getKeyword1(),
        ji.getKeyword2(), ji.getKeyword3(), ji.getModule(), jd.getKeyword1(), jd.getKeyword2(), jd.getKeyword3(),
        jd.getModule(), n == null ? null : n.getName(), ji.getParentId(), ji.getProgress(), q == null ? null : q.getName(), 0,
        ji.getSessionID(), finalState.toString(), ji.getUserName(), ji.getJdId(), n == null ? null : n.getId(), ji.getQueue(),
        ji.isFromSchedule(), ji.getPriority());
  }
  else
  {
    cnx.runUpdate("history_insert_with_end_date", ji.getId(), jd.getApplication(), jd.getApplicationName(), ji.getAttributionDate(),
        ji.getEmail(), endDate, ji.getCreationDate(), ji.getExecutionDate(), jd.isHighlander(), ji.getApplication(),
        ji.getKeyword1(), ji.getKeyword2(), ji.getKeyword3(), ji.getModule(), jd.getKeyword1(), jd.getKeyword2(),
        jd.getKeyword3(), jd.getModule(), n.getName(), ji.getParentId(), ji.getProgress(), q.getName(), 0, ji.getSessionID(),
        finalState.toString(), ji.getUserName(), ji.getJdId(), ji.getNode().getId(), ji.getQueue(), ji.isFromSchedule(),
        ji.getPriority());
  }
}

内容来源于网络，如有侵权，请联系作者删除！

queue

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com