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

x33g5p2x  于2022-01-25 转载在 其他  
字(11.0k)|赞(0)|评价(0)|浏览(113)

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

Node.getName介绍

[英]The functional key of the node. When starting an engine, it is given this name as its only parameter. It must be unique.
Max length is 100.
[中]节点的功能键。当启动引擎时，它的唯一参数就是这个名字。它必须是独一无二的。
最大长度为100。

代码示例

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

/**
 * This actually starts the different engines configured with {@link #addNode(String)}.<br>
 * This can usually only be called once (it can actually be called again but only after calling {@link #stop()}).
 */
public JqmAsyncTester start()
{
  if (hasStarted)
  {
    throw new IllegalStateException("cannot start twice");
  }
  if (nodes.isEmpty())
  {
    throw new IllegalStateException("no engines defined");
  }
  if (queues.isEmpty())
  {
    throw new IllegalStateException("no queues defined");
  }
  if (!oneQueueDeployed)
  {
    throw new IllegalStateException("no queue was ever deployed to any node");
  }
  hasStarted = true;
  for (Node n : nodes.values())
  {
    engines.put(n.getName(), JqmEngineFactory.startEngine(n.getName(), null));
  }
  return this;
}

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

/**
 * This actually starts the different engines configured with {@link #addNode(String)}.<br>
 * This can usually only be called once (it can actually be called again but only after calling {@link #stop()}).
 */
public JqmAsyncTester start()
{
  if (hasStarted)
  {
    throw new IllegalStateException("cannot start twice");
  }
  if (nodes.isEmpty())
  {
    throw new IllegalStateException("no engines defined");
  }
  if (queues.isEmpty())
  {
    throw new IllegalStateException("no queues defined");
  }
  if (!oneQueueDeployed)
  {
    throw new IllegalStateException("no queue was ever deployed to any node");
  }
  hasStarted = true;
  for (Node n : nodes.values())
  {
    engines.put(n.getName(), JqmEngineFactory.startEngine(n.getName(), null));
  }
  return this;
}

代码示例来源：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: enioka/jqm

jqmlogger.info("JQM engine " + this.node.getName() + " has received a stop order");
jqmlogger.debug("Stop order was correctly handled. Engine for node " + this.node.getName() + " has stopped.");

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

jqmlogger.info("JQM engine " + this.node.getName() + " has received a stop order");
jqmlogger.debug("Stop order was correctly handled. Engine for node " + this.node.getName() + " has stopped.");

代码示例来源：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

@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

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: 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

webAppContext.setInitParameter("jqmnode", node.getName());
webAppContext.setInitParameter("jqmnodeid", node.getId().toString());

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

webAppContext.setInitParameter("jqmnode", node.getName());
webAppContext.setInitParameter("jqmnodeid", node.getId().toString());

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

env.put("JQM_JI_DELIVERY_DIR", this.deliveryDir.getAbsolutePath());
env.put("JQM_NODE_NAME", this.ji.getNode().getName());
env.put("JQM_NODE_APPLICATION_ROOT", this.ji.getNode().getRepo());
env.put("JQM_NODE_LOG_LEVEL", this.ji.getNode().getRootLogLevel());

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

env.put("JQM_JI_DELIVERY_DIR", this.deliveryDir.getAbsolutePath());
env.put("JQM_NODE_NAME", this.ji.getNode().getName());
env.put("JQM_NODE_APPLICATION_ROOT", this.ji.getNode().getRepo());
env.put("JQM_NODE_LOG_LEVEL", this.ji.getNode().getRootLogLevel());

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

name = new ObjectName("com.enioka.jqm:type=Node,name=" + this.node.getName());
    mbs.registerMBean(this, name);
JqmEngine.latestNodeStartedName = node.getName();
if (this.handler != null)

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

.info("Poller loop on queue " + this.queue.getName() + " is stopping [engine " + this.engine.getNode().getName() + "]");
waitForAllThreads(60L * 1000);

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

@Test
  public void testTemplate() throws Exception
  {
    NodeDto template = MetaService.getNode(cnx, TestHelpers.nodeMix.getId());
    template.setPort(123);
    MetaService.upsertNode(cnx, template);
    cnx.commit();

    NodeDto target = MetaService.getNode(cnx, TestHelpers.node.getId());
    Assert.assertEquals(3, MetaService.getNodeQueueMappings(cnx, target.getId()).size());

    // Capital letter -> should be ignored.
    Main.runCommand(new String[] { "Install-NodeTemPlate", "-t", TestHelpers.nodeMix.getName(), "-n", TestHelpers.node.getName() });

    target = MetaService.getNode(cnx, TestHelpers.node.getId());

    Assert.assertEquals(template.getPort(), target.getPort());
    Assert.assertEquals(1, MetaService.getNodeQueueMappings(cnx, target.getId()).size());
  }
}

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

"com.enioka.jqm:type=Node.Queue.JobInstance,Node=" + TestHelpers.node.getName() + ",Queue=VIPQueue,name=" + i);
System.out.println("Name to kill: " + killBean.toString());
mbeans = mbsc.queryMBeans(killBean, null);
ObjectName engine = new ObjectName("com.enioka.jqm:type=Node,name=" + TestHelpers.node.getName());
JqmEngineMBean proxyEngine = JMX.newMBeanProxy(mbsc, engine, JqmEngineMBean.class);
Assert.assertEquals(1, proxyEngine.getCumulativeJobInstancesCount() + proxyEngine.getCurrentlyRunningJobCount());
ObjectName poller = new ObjectName("com.enioka.jqm:type=Node.Queue,Node=" + TestHelpers.node.getName() + ",name=VIPQueue");
QueuePollerMBean proxyPoller = JMX.newMBeanProxy(mbsc, poller, QueuePollerMBean.class);
Assert.assertEquals(1, proxyPoller.getCumulativeJobInstancesCount() + proxyPoller.getCurrentActiveThreadCount());

代码示例来源：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());
  }
}

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

Node

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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