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

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

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

Node.getId介绍

[英]A technical ID without any meaning. Generated by the database.
[中]没有任何意义的技术ID。由数据库生成。

代码示例

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

  1. /**
  2.  * See {@link #getNode()}
  3.  */
  4. public void setNode(final Node node)
  5. {
  6.   this.n = node;
  7.   this.node_id = node.getId();
  8. }

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

  1. /**
  2.  * See {@link #getNode()}
  3.  */
  4. public void setNode(final Node node)
  5. {
  6.   this.n = node;
  7.   this.node_id = node.getId();
  8. }

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

  1. public static DeploymentParameter create(DbConn cnx, Node node, Integer nbThread, Integer pollingInterval, Integer queueId)
  2. {
  3.   return create(cnx, node.getId(), nbThread, pollingInterval, queueId);
  4. }

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

  1. public static DeploymentParameter create(DbConn cnx, Node node, Integer nbThread, Integer pollingInterval, Integer queueId)
  2. {
  3.   return create(cnx, node.getId(), nbThread, pollingInterval, queueId);
  4. }

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

  1. @Override
  2.   public String getWebApiLocalUrl(DbConn cnx)
  3.   {
  4.     // Do not use port from engine.getNode, as it may have been set AFTER engine startup.
  5.     Node node = Node.select_single(cnx, "node_select_by_id", this.engine.getNode().getId());
  6.     boolean useSsl = Boolean.parseBoolean(GlobalParameter.getParameter(cnx, "enableWsApiSsl", "false"));
  7.     return (useSsl ? "https://localhost:" : "http://localhost:") + node.getPort();
  8.   }
  9. }

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

  1. @Override
  2.   public String getWebApiLocalUrl(DbConn cnx)
  3.   {
  4.     // Do not use port from engine.getNode, as it may have been set AFTER engine startup.
  5.     Node node = Node.select_single(cnx, "node_select_by_id", this.engine.getNode().getId());
  6.     boolean useSsl = Boolean.parseBoolean(GlobalParameter.getParameter(cnx, "enableWsApiSsl", "false"));
  7.     return (useSsl ? "https://localhost:" : "http://localhost:") + node.getPort();
  8.   }
  9. }

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

  1. @Override
  2. public long getCumulativeJobInstancesCount()
  3. {
  4.   DbConn em2 = Helpers.getNewDbSession();
  5.   try
  6.   {
  7.     return em2.runSelectSingle("history_select_count_for_poller", Long.class, this.queue.getId(), this.engine.getNode().getId());
  8.   }
  9.   finally
  10.   {
  11.     Helpers.closeQuietly(em2);
  12.   }
  13. }

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

  1. @Before
  2. public void before() throws IOException
  3. {
  4.   Helpers.setSingleParam("disableWsApi", "false", cnx);
  5.   Helpers.setSingleParam("enableWsApiAuth", "false", cnx);
  6.   File jar = FileUtils.listFiles(new File("../jqm-ws/target/"), new String[] { "war" }, false).iterator().next();
  7.   FileUtils.copyFile(jar, new File("./webapp/jqm-ws.war"));
  8.   addAndStartEngine();
  9.   TestHelpers.node = Node.select_single(cnx, "node_select_by_id", TestHelpers.node.getId());
  10. }

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

  1. @Override
  2. public long getCumulativeJobInstancesCount()
  3. {
  4.   DbConn em2 = Helpers.getNewDbSession();
  5.   try
  6.   {
  7.     return em2.runSelectSingle("history_select_count_for_poller", Long.class, this.queue.getId(), this.engine.getNode().getId());
  8.   }
  9.   finally
  10.   {
  11.     Helpers.closeQuietly(em2);
  12.   }
  13. }

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

  1. @Override
  2. public float getJobsFinishedPerSecondLastMinute()
  3. {
  4.   DbConn em2 = Helpers.getNewDbSession();
  5.   try
  6.   {
  7.     return em2.runSelectSingle("history_select_count_last_mn_for_poller", Float.class, this.queue.getId(),
  8.         this.engine.getNode().getId());
  9.   }
  10.   finally
  11.   {
  12.     Helpers.closeQuietly(em2);
  13.   }
  14. }

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

  1. @Override
  2. public float getJobsFinishedPerSecondLastMinute()
  3. {
  4.   DbConn em2 = Helpers.getNewDbSession();
  5.   try
  6.   {
  7.     return em2.runSelectSingle("history_select_count_last_mn_for_poller", Float.class, this.queue.getId(),
  8.         this.engine.getNode().getId());
  9.   }
  10.   finally
  11.   {
  12.     Helpers.closeQuietly(em2);
  13.   }
  14. }

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

  1. @Override
  2. public void resume()
  3. {
  4.   DbConn cnx = null;
  5.   try
  6.   {
  7.     cnx = Helpers.getNewDbSession();
  8.     cnx.runUpdate("node_update_enabled_by_id", Boolean.TRUE, node.getId());
  9.     cnx.commit();
  10.   }
  11.   finally
  12.   {
  13.     Helpers.closeQuietly(cnx);
  14.   }
  15.   refreshConfiguration();
  16. }

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

  1. @Override
  2. public void pause()
  3. {
  4.   DbConn cnx = null;
  5.   try
  6.   {
  7.     cnx = Helpers.getNewDbSession();
  8.     cnx.runUpdate("node_update_enabled_by_id", Boolean.FALSE, node.getId());
  9.     cnx.commit();
  10.   }
  11.   finally
  12.   {
  13.     Helpers.closeQuietly(cnx);
  14.   }
  15.   refreshConfiguration();
  16. }

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

  1. @Override
  2. public void pause()
  3. {
  4.   DbConn cnx = null;
  5.   try
  6.   {
  7.     cnx = Helpers.getNewDbSession();
  8.     cnx.runUpdate("node_update_enabled_by_id", Boolean.FALSE, node.getId());
  9.     cnx.commit();
  10.   }
  11.   finally
  12.   {
  13.     Helpers.closeQuietly(cnx);
  14.   }
  15.   refreshConfiguration();
  16. }

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

  1. @Test
  2. public void testRemoteStop() throws Exception
  3. {
  4.   Helpers.setSingleParam("internalPollingPeriodMs", "10", cnx);
  5.   addAndStartEngine();
  6.   cnx.runUpdate("node_update_stop_by_id", TestHelpers.node.getId());
  7.   cnx.commit();
  8.   TestHelpers.waitFor(2, 3000, cnx);
  9.   Assert.assertFalse(engines.get("localhost").areAllPollersPolling());
  10.   engines.clear();
  11. }

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

  1. @Test
  2.   public void testTemplate() throws Exception
  3.   {
  4.     NodeDto template = MetaService.getNode(cnx, TestHelpers.nodeMix.getId());
  5.     template.setPort(123);
  6.     MetaService.upsertNode(cnx, template);
  7.     cnx.commit();
  9.     NodeDto target = MetaService.getNode(cnx, TestHelpers.node.getId());
  10.     Assert.assertEquals(3, MetaService.getNodeQueueMappings(cnx, target.getId()).size());
  12.     // Capital letter -> should be ignored.
  13.     Main.runCommand(new String[] { "Install-NodeTemPlate", "-t", TestHelpers.nodeMix.getName(), "-n", TestHelpers.node.getName() });
  15.     target = MetaService.getNode(cnx, TestHelpers.node.getId());
  17.     Assert.assertEquals(template.getPort(), target.getPort());
  18.     Assert.assertEquals(1, MetaService.getNodeQueueMappings(cnx, target.getId()).size());
  19.   }
  20. }

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

  1. @Test
  2.   public void testPauseResume() throws Exception
  3.   {
  4.     cnx.runUpdate("node_update_enabled_by_id", false, TestHelpers.node.getId());
  5.     cnx.commit();
  7.     // Submit request => nothing should happen
  8.     JqmSimpleTest.create(cnx, "pyl.PckMain", "jqm-test-pyl-nodep").addWaitTime(3000).expectNonOk(0).expectOk(0).run(this);
  10.     // Resume => JI should be run and end OK
  11.     this.engines.get("localhost").resume();
  12.     TestHelpers.waitFor(1, 5000, cnx);
  13.     Assert.assertEquals(1, TestHelpers.getOkCount(cnx));
  14.   }
  15. }

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

  1. @Test(expected = JqmInvalidRequestException.class)
  2. public void testPriorityLimits()
  3. {
  4.   int qId = Queue.create(cnx, "testqueue", " ", false);
  5.   DeploymentParameter.create(cnx, TestHelpers.node.getId(), 1, 1, qId);
  6.   CreationTools.createJobDef(null, true, "pyl.Wait", null, "jqm-tests/jqm-test-pyl-nodep/target/test.jar", qId, 42, "jqm-test-wait",
  7.       null, "Franquin", "ModuleMachin", "other", "other", false, cnx);
  8.   cnx.commit();
  9.   // No priority = FIFO queue.
  10.   JobRequest.create("jqm-test-wait", "test").addParameter("ms", "100").setPriority(Integer.MAX_VALUE).submit();
  11. }

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

  1. @Test
  2. public void testStartupCleanupAttr() throws Exception
  3. {
  4.   CreationTools.createJobDef(null, true, "App", null, "jqm-tests/jqm-test-em/target/test.jar", TestHelpers.qVip, 42, "jqm-test-em",
  5.       null, "Franquin", "ModuleMachin", "other", "other", false, cnx);
  6.   // Create a running job that should be cleaned at startup
  7.   int i = JqmClientFactory.getClient().enqueue("jqm-test-em", "test");
  8.   cnx.runUpdate("ji_update_status_by_id", TestHelpers.node.getId(), i);
  9.   cnx.commit();
  10.   addAndStartEngine();
  11.   Assert.assertEquals(0, TestHelpers.getQueueAllCount(cnx));
  12.   Assert.assertEquals(1, TestHelpers.getHistoryAllCount(cnx));
  13.   Assert.assertEquals(1, TestHelpers.getNonOkCount(cnx));
  14. }

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

  1. @Test
  2. public void testStartupCleanupRunning() throws Exception
  3. {
  4.   CreationTools.createJobDef(null, true, "App", null, "jqm-tests/jqm-test-em/target/test.jar", TestHelpers.qVip, 42, "jqm-test-em",
  5.       null, "Franquin", "ModuleMachin", "other", "other", false, cnx);
  6.   /// Create a running job that should be cleaned at startup
  7.   int i1 = JqmClientFactory.getClient().enqueue("jqm-test-em", "test");
  8.   cnx.runUpdate("ji_update_status_by_id", TestHelpers.node.getId(), i1);
  9.   cnx.runUpdate("jj_update_run_by_id", i1);
  10.   cnx.commit();
  11.   addAndStartEngine();
  12.   Assert.assertEquals(0, TestHelpers.getQueueAllCount(cnx));
  13.   Assert.assertEquals(1, TestHelpers.getHistoryAllCount(cnx));
  14.   Assert.assertEquals(1, TestHelpers.getNonOkCount(cnx));
  15. }

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

Node

相关文章

    查看更多

    热门标签

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

    最新文章

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