gpt4 book ai didi

net.sf.taverna.t2.workflowmodel.WorkflowStructureException.()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-23 23:33:05 24 4
gpt4 key购买 nike

本文整理了Java中net.sf.taverna.t2.workflowmodel.WorkflowStructureException.<init>()方法的一些代码示例,展示了WorkflowStructureException.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkflowStructureException.<init>()方法的具体详情如下:
包路径:net.sf.taverna.t2.workflowmodel.WorkflowStructureException
类名称:WorkflowStructureException
方法名:<init>

WorkflowStructureException.<init>介绍

暂无

代码示例

代码示例来源:origin: net.sf.taverna.t2/maelstrom-impl

public void completionCreated(Completion completion) {
  throw new WorkflowStructureException(
      "Should never see this if everything is working,"
          + "if this occurs it is likely that the internal "
          + "logic is broken, talk to Tom");
}

代码示例来源:origin: net.sf.taverna.t2/workflowmodel-impl

public void completionCreated(Completion completion) {
  throw new WorkflowStructureException(
      "Should never see this if everything is working,"
          + "if this occurs it is likely that the internal "
          + "logic is broken, talk to Tom");
}

代码示例来源:origin: net.sf.taverna.t2.core/workflowmodel-impl

public void completionCreated(Completion completion) {
  throw new WorkflowStructureException(
      "Should never see this if everything is working,"
          + "if this occurs it is likely that the internal "
          + "logic is broken, talk to Tom");
}

代码示例来源:origin: net.sf.taverna.t2/maelstrom-impl

public void receiveJob(Job job, List<? extends Activity<?>> activities) {
  throw new WorkflowStructureException(
      "Parallelize layer cannot handle job events");
}

代码示例来源:origin: net.sf.taverna.t2.core/workflowmodel-core-extensions

public void receiveJob(Job job, List<? extends Activity<?>> activities) {
  throw new WorkflowStructureException(
      "Parallelize layer cannot handle job events");
}

代码示例来源:origin: net.sf.taverna.t2/workflowmodel-impl

public void receiveJob(Job job, List<? extends Activity<?>> activities) {
  throw new WorkflowStructureException(
      "Parallelize layer cannot handle job events");
}

代码示例来源:origin: net.sf.taverna.t2/maelstrom-impl

public void addStrategy(IterationStrategy is) {
  if (is instanceof IterationStrategyImpl) {
    IterationStrategyImpl isi = (IterationStrategyImpl) is;
    strategies.add(isi);
    isi.setIterationStrategyStack(this);
  } else {
    throw new WorkflowStructureException(
        "IterationStrategyStackImpl can only hold IterationStrategyImpl objects");
  }
}

代码示例来源:origin: net.sf.taverna.t2.core/workflowmodel-impl

private NamedInputPortNode nodeForName(String portName)
    throws WorkflowStructureException {
  for (NamedInputPortNode node : inputs) {
    if (node.getPortName().equals(portName)) {
      return node;
    }
  }
  throw new WorkflowStructureException("No port found with name '"
      + portName + "'");
}

代码示例来源:origin: net.sf.taverna.t2.core/workflowmodel-impl

public void addStrategy(IterationStrategy is) {
  if (is instanceof IterationStrategyImpl) {
    IterationStrategyImpl isi = (IterationStrategyImpl) is;
    strategies.add(isi);
    isi.setIterationStrategyStack(this);
  } else {
    throw new WorkflowStructureException(
        "IterationStrategyStackImpl can only hold IterationStrategyImpl objects");
  }
}

代码示例来源:origin: net.sf.taverna.t2/workflowmodel-impl

private NamedInputPortNode nodeForName(String portName)
    throws WorkflowStructureException {
  for (NamedInputPortNode node : inputs) {
    if (node.getPortName().equals(portName)) {
      return node;
    }
  }
  throw new WorkflowStructureException("No port found with name '"
      + portName + "'");
}

代码示例来源:origin: net.sf.taverna.t2/maelstrom-impl

private NamedInputPortNode nodeForName(String portName)
    throws WorkflowStructureException {
  for (NamedInputPortNode node : inputs) {
    if (node.getPortName().equals(portName)) {
      return node;
    }
  }
  throw new WorkflowStructureException("No port found with name '"
      + portName + "'");
}

代码示例来源:origin: net.sf.taverna.t2.core/workflowmodel-impl

public void removeStrategy(IterationStrategy is) {
  if (is instanceof IterationStrategyImpl) {
    IterationStrategyImpl isi = (IterationStrategyImpl) is;
    strategies.remove(isi);
    isi.setIterationStrategyStack(null);
  } else {
    throw new WorkflowStructureException(
        "IterationStrategyStackImpl can only hold IterationStrategyImpl objects");
  }
}

代码示例来源:origin: net.sf.taverna.t2/workflowmodel-impl

public void addStrategy(IterationStrategy is) {
  if (is instanceof IterationStrategyImpl) {
    IterationStrategyImpl isi = (IterationStrategyImpl) is;
    strategies.add(isi);
    isi.setIterationStrategyStack(this);
  } else {
    throw new WorkflowStructureException(
        "IterationStrategyStackImpl can only hold IterationStrategyImpl objects");
  }
}

代码示例来源:origin: net.sf.taverna.t2/maelstrom-impl

public void eventAdded(String owningProcess) {
  if (! stateMap.containsKey(owningProcess)) {
    throw new WorkflowStructureException(
        "Should never see this here, it means we've had duplicate completion events from upstream");
  } else {
    synchronized (stateMap.get(owningProcess)) {
      stateMap.get(owningProcess).fillFromQueue();
    }
  }
}

代码示例来源:origin: net.sf.taverna.t2.core/workflowmodel-core-extensions

public void eventAdded(String owningProcess) {
  StateModel stateModel;
  synchronized (stateMap) {
    stateModel = stateMap.get(owningProcess);
  }
  if (stateModel == null) {
    /*
     * Should never see this here, it means we've had duplicate
     * completion events from upstream
     */
    throw new WorkflowStructureException(
        "Unknown owning process " + owningProcess);		
  }
  synchronized (stateModel) {
    stateModel.fillFromQueue();
  }
}

代码示例来源:origin: net.sf.taverna.t2/workflowmodel-impl

public void eventAdded(String owningProcess) {
  StateModel stateModel;
  synchronized (stateMap) {
    stateModel = stateMap.get(owningProcess);
  }
  if (stateModel == null) {
    /*
     * Should never see this here, it means we've had duplicate
     * completion events from upstream
     */
    throw new WorkflowStructureException(
        "Unknown owning process " + owningProcess);		
  }
  synchronized (stateModel) {
    stateModel.fillFromQueue();
  }
}

代码示例来源:origin: net.sf.taverna.t2/maelstrom-api

/**
 * Push the specified job up to the parent node in the iteration strategy.
 */
protected final void pushJob(Job job) {
  if (parent != null) {
    int index = parent.getIndex(this);
    if (index < 0) {
      throw new WorkflowStructureException(
          "Parent doesn't have this node in its child list!");
    }
    parent.receiveJob(parent.getIndex(this), job);
  }
}

代码示例来源:origin: net.sf.taverna.t2.core/workflowmodel-api

/**
 * Push the specified job up to the parent node in the iteration strategy.
 */
protected final void pushJob(Job job) {
  if (parent != null) {
    int index = parent.getIndex(this);
    if (index < 0) {
      throw new WorkflowStructureException(
          "Parent doesn't have this node in its child list!");
    }
    parent.receiveJob(parent.getIndex(this), job);
  }
}

代码示例来源:origin: net.sf.taverna.t2/workflowmodel-api

/**
 * Push the specified job up to the parent node in the iteration strategy.
 */
protected final void pushJob(Job job) {
  if (parent != null) {
    int index = parent.getIndex(this);
    if (index < 0) {
      throw new WorkflowStructureException(
          "Parent doesn't have this node in its child list!");
    }
    parent.receiveJob(parent.getIndex(this), job);
  }
}

代码示例来源:origin: net.sf.taverna.t2/maelstrom-impl

protected void receiveEvent(WorkflowDataToken token, String portName) {
  int portIndex = inputPortNameToIndex(portName);
  if (portIndex == -1) {
    throw new WorkflowStructureException(
        "Received event on a port that doesn't exist, huh?");
  }
  int[] currentIndex = token.getIndex();
  int[] newIndex = new int[currentIndex.length + 1];
  newIndex[0] = portIndex;
  for (int i = 0; i < currentIndex.length; i++) {
    newIndex[i + 1] = currentIndex[i];
  }
  output.sendEvent(new WorkflowDataToken(token.getOwningProcess(),
      newIndex, token.getData(), token.getContext()));
}

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com