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

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

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

Node.getDlRepo介绍

[英]The directory that will store all the Deliverables created by job instances.
Max length is 1024.
[中]将存储作业实例创建的所有可交付成果的目录。
最大长度为1024。

代码示例

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

jqmlogger.info("\tfile produced storage directory: " + n.getDlRepo());
jqmlogger.info("\tHTTP listening interface: " + n.getDns());
jqmlogger.info("\tlooks for payloads inside: " + n.getRepo());

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

jqmlogger.info("\tfile produced storage directory: " + n.getDlRepo());
jqmlogger.info("\tHTTP listening interface: " + n.getDns());
jqmlogger.info("\tlooks for payloads inside: " + n.getRepo());

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

/**
   * Version of {@link JqmClient#getDeliverableContent(Deliverable)} which does not require the web service APIs to be enabled to work.
   * Also, returned files do not self-destruct on stream close.<br>
   * See the javadoc of the original method for details.
   * 
   * @throws FileNotFoundException
   */
  public InputStream getDeliverableContent(Deliverable file) throws FileNotFoundException
  {
    List<com.enioka.jqm.model.Deliverable> dd = com.enioka.jqm.model.Deliverable.select(cnx, "deliverable_select_by_id", file.getId());
    if (dd.isEmpty())
    {
      throw new JqmInvalidRequestException("no deliverable with this ID");
    }

    com.enioka.jqm.model.Deliverable d = dd.get(0);
    JobInstance ji = Query.create().setJobInstanceId(d.getJobId()).run().get(0);
    String nodeName = ji.getNodeName();
    Node n = nodes.get(nodeName);

    return new FileInputStream(FilenameUtils.concat(n.getDlRepo(), file.getFilePath()));
  }
}

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

/**
   * Version of {@link JqmClient#getDeliverableContent(Deliverable)} which does not require the web service APIs to be enabled to work.
   * Also, returned files do not self-destruct on stream close.<br>
   * See the javadoc of the original method for details.
   * 
   * @throws FileNotFoundException
   */
  public InputStream getDeliverableContent(Deliverable file) throws FileNotFoundException
  {
    List<com.enioka.jqm.model.Deliverable> dd = com.enioka.jqm.model.Deliverable.select(cnx, "deliverable_select_by_id", file.getId());
    if (dd.isEmpty())
    {
      throw new JqmInvalidRequestException("no deliverable with this ID");
    }

    com.enioka.jqm.model.Deliverable d = dd.get(0);
    JobInstance ji = Query.create().setJobInstanceId(d.getJobId()).run().get(0);
    String nodeName = ji.getNodeName();
    Node n = nodes.get(nodeName);

    return new FileInputStream(FilenameUtils.concat(n.getDlRepo(), file.getFilePath()));
  }
}

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

@Override
public Integer addDeliverable(String path, String fileLabel)
{
  DbConn cnx = Helpers.getNewDbSession();
  try
  {
    String outputRoot = this.ji.getNode().getDlRepo();
    String ext = FilenameUtils.getExtension(path);
    String relDestPath = ji.getJD().getApplicationName() + "/" + ji.getId() + "/" + UUID.randomUUID() + "." + ext;
    String absDestPath = FilenameUtils.concat(outputRoot, relDestPath);
    String fileName = FilenameUtils.getName(path);
    jqmlogger.debug("A deliverable is added. Stored as " + absDestPath + ". Initial name: " + fileName);
    FileUtils.moveFile(new File(path), new File(absDestPath));
    cnx.commit();
    int res = Helpers.createDeliverable(relDestPath, fileName, fileLabel, this.ji.getId(), cnx);
    cnx.commit();
    return res;
  }
  catch (IOException e)
  {
    throw new JqmClientException(e);
  }
  finally
  {
    Helpers.closeQuietly(cnx);
  }
}

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

File f = TestHelpers.node == null ? null : new File(TestHelpers.node.getDlRepo());
if (f != null && f.isDirectory())
  FileUtils.cleanDirectory(new File(TestHelpers.node.getDlRepo()));

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

@Override
public Integer addDeliverable(String path, String fileLabel)
{
  DbConn cnx = Helpers.getNewDbSession();
  try
  {
    String outputRoot = this.ji.getNode().getDlRepo();
    String ext = FilenameUtils.getExtension(path);
    String relDestPath = ji.getJD().getApplicationName() + "/" + ji.getId() + "/" + UUID.randomUUID() + "." + ext;
    String absDestPath = FilenameUtils.concat(outputRoot, relDestPath);
    String fileName = FilenameUtils.getName(path);
    jqmlogger.debug("A deliverable is added. Stored as " + absDestPath + ". Initial name: " + fileName);
    FileUtils.moveFile(new File(path), new File(absDestPath));
    cnx.commit();
    int res = Helpers.createDeliverable(relDestPath, fileName, fileLabel, this.ji.getId(), cnx);
    cnx.commit();
    return res;
  }
  catch (IOException e)
  {
    throw new JqmClientException(e);
  }
  finally
  {
    Helpers.closeQuietly(cnx);
  }
}

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

File f = TestHelpers.node == null ? null : new File(TestHelpers.node.getDlRepo());
if (f != null && f.isDirectory())
  FileUtils.cleanDirectory(new File(TestHelpers.node.getDlRepo()));

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

if (!StringUtils.hasText(nn.getDlRepo()) || !StringUtils.hasText(nn.getRepo()) || !StringUtils.hasText(nn.getTmpDirectory()))

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

if (!StringUtils.hasText(nn.getDlRepo()) || !StringUtils.hasText(nn.getRepo()) || !StringUtils.hasText(nn.getTmpDirectory()))

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

/**
 * Retrieve all the files created by a job, with auth, without SSL
 */
@Test
public void testGetDeliverables() throws Exception
{
  Helpers.setSingleParam("disableWsApi", "false", cnx);
  Helpers.setSingleParam("enableWsApiAuth", "true", cnx);
  Helpers.setSingleParam("enableWsApiSsl", "false", cnx);
  int id = JqmSimpleTest.create(cnx, "pyl.EngineApiSendDeliverable").addDefParameter("filepath", TestHelpers.node.getDlRepo())
      .addDefParameter("fileName", "jqm-test-deliverable1.txt").run(this);
  List<InputStream> tmp = JqmClientFactory.getClient().getJobDeliverablesContent(id);
  // Assert.assertTrue(tmp.get(0).available() > 0);
  String res = IOUtils.toString(tmp.get(0), Charset.defaultCharset());
  Assert.assertTrue(res.startsWith("Hello World!"));
  tmp.get(0).close();
}

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

/**
 * Retrieve a remote file with authentication, without SSL.
 */
@Test
public void testGetOneDeliverableWithAuth() throws Exception
{
  Helpers.setSingleParam("disableWsApi", "false", cnx);
  Helpers.setSingleParam("enableWsApiAuth", "true", cnx);
  Helpers.setSingleParam("enableWsApiSsl", "false", cnx);
  int jobId = JqmSimpleTest.create(cnx, "pyl.EngineApiSendDeliverable").addDefParameter("filepath", TestHelpers.node.getDlRepo())
      .addDefParameter("fileName", "jqm-test-deliverable2.txt").run(this);
  File f = new File(TestHelpers.node.getDlRepo() + "jqm-test-deliverable2.txt");
  Assert.assertEquals(false, f.exists()); // file should have been moved
  List<com.enioka.jqm.api.Deliverable> files = JqmClientFactory.getClient().getJobDeliverables(jobId);
  Assert.assertEquals(1, files.size());
  InputStream tmp = JqmClientFactory.getClient().getDeliverableContent(files.get(0));
  Assert.assertTrue(tmp.available() > 0);
  String res = IOUtils.toString(tmp, Charset.defaultCharset());
  Assert.assertTrue(res.startsWith("Hello World!"));
  tmp.close();
}

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

/**
 * Same as above, except authentication is disabled as well as SSL.
 */
@Test
public void testGetOneDeliverableWithoutAuth() throws Exception
{
  Helpers.setSingleParam("disableWsApi", "false", cnx);
  Helpers.setSingleParam("enableWsApiAuth", "false", cnx);
  Helpers.setSingleParam("enableWsApiSsl", "false", cnx);
  int jobId = JqmSimpleTest.create(cnx, "pyl.EngineApiSendDeliverable").addDefParameter("filepath", TestHelpers.node.getDlRepo())
      .addDefParameter("fileName", "jqm-test-deliverable3.txt").run(this);
  File f = new File(TestHelpers.node.getDlRepo() + "jqm-test-deliverable3.txt");
  Assert.assertEquals(false, f.exists()); // file should have been moved
  List<com.enioka.jqm.api.Deliverable> files = JqmClientFactory.getClient().getJobDeliverables(jobId);
  Assert.assertEquals(1, files.size());
  InputStream tmp = JqmClientFactory.getClient().getDeliverableContent(files.get(0));
  Assert.assertTrue(tmp.available() > 0);
  String res = IOUtils.toString(tmp, Charset.defaultCharset());
  Assert.assertTrue(res.startsWith("Hello World!"));
  tmp.close();
}

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

/**
 * Retrieve a remote file with authentication, with SSL.
 */
@Test
public void testGetOneDeliverableWithAuthWithSsl() throws Exception
{
  Helpers.setSingleParam("disableWsApi", "false", cnx);
  Helpers.setSingleParam("enableWsApiAuth", "true", cnx);
  Helpers.setSingleParam("enableWsApiSsl", "true", cnx);
  JqmClientFactory.resetClient(null);
  JqmClientFactory.setProperty("com.enioka.jqm.ws.truststoreFile", "./conf/trusted.jks");
  JqmClientFactory.setProperty("com.enioka.jqm.ws.truststorePass", "SuperPassword");
  int jobId = JqmSimpleTest.create(cnx, "pyl.EngineApiSendDeliverable").addDefParameter("filepath", TestHelpers.node.getDlRepo())
      .addDefParameter("fileName", "jqm-test-deliverable4.txt").run(this);
  File f = new File(TestHelpers.node.getDlRepo() + "jqm-test-deliverable4.txt");
  Assert.assertEquals(false, f.exists()); // file should have been moved
  List<com.enioka.jqm.api.Deliverable> files = JqmClientFactory.getClient().getJobDeliverables(jobId);
  Assert.assertEquals(1, files.size());
  InputStream tmp = JqmClientFactory.getClient().getDeliverableContent(files.get(0));
  Assert.assertTrue(tmp.available() > 0);
  String res = IOUtils.toString(tmp, Charset.defaultCharset());
  Assert.assertTrue(res.startsWith("Hello World!"));
  tmp.close();
}

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

/**
   * This test is DB only - no simple service use
   */
  @Test
  public void testGetAllDeliverables() throws Exception
  {
    int jobId = JqmSimpleTest.create(cnx, "pyl.EngineApiSendDeliverable").addDefParameter("filepath", TestHelpers.node.getDlRepo())
        .addDefParameter("fileName", "jqm-test-deliverable5.txt").run(this);

    List<com.enioka.jqm.api.Deliverable> tmp = JqmClientFactory.getClient().getJobDeliverables(jobId);
    Assert.assertEquals(1, tmp.size());
  }
}

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

tmp.add("NormalQueue");
XmlQueueExporter.export(TestHelpers.node.getDlRepo() + "xmlexportqueuetest.xml", cnx, tmp);
File t = new File(TestHelpers.node.getDlRepo() + "xmlexportqueuetest.xml");
Assert.assertEquals(true, t.exists());
XmlQueueParser.parse(TestHelpers.node.getDlRepo() + "xmlexportqueuetest.xml", cnx);

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

"DateTime", null, "Franquin", "ModuleMachin", "other", "other", false, cnx);
XmlQueueExporter.export(TestHelpers.node.getDlRepo() + "xmlexportqueuetest.xml", cnx);
File t = new File(TestHelpers.node.getDlRepo() + "xmlexportqueuetest.xml");
Assert.assertEquals(true, t.exists());
XmlQueueParser.parse(TestHelpers.node.getDlRepo() + "xmlexportqueuetest.xml", cnx);

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

TestHelpers.dpSlow3 = DeploymentParameter.create(cnx, node3, 1, 1000, qSlow3);
if (!(new File(TestHelpers.node.getDlRepo())).isDirectory() && !(new File(TestHelpers.node.getDlRepo())).mkdir())

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

TestHelpers.dpSlow3 = DeploymentParameter.create(cnx, node3, 1, 1000, qSlow3);
if (!(new File(TestHelpers.node.getDlRepo())).isDirectory() && !(new File(TestHelpers.node.getDlRepo())).mkdir())

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

"DateTime2", null, "Franquin", "ModuleMachin", "other", "other", false, cnx);
XmlJobDefExporter.export(TestHelpers.node.getDlRepo() + "xmlexportjobdeftest.xml", cnx);
File f = new File(TestHelpers.node.getDlRepo() + "xmlexportjobdeftest.xml");
Assert.assertEquals(true, f.exists());
XmlJobDefParser.parse(TestHelpers.node.getDlRepo() + "xmlexportjobdeftest.xml", cnx);

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

Node

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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