List of registerTask() Examples

Examples of registerTask()

net.sourceforge.ganttproject.task.TaskManager.registerTask()
org.apache.hama.bsp.sync.ZooKeeperSyncClientImpl.registerTask()
Registers the task from outside, most of the time used by the groom which uses this at task spawn-time. @param zk @param jobId @param taskId @param hostAddress @param port @param taskId
org.wso2.carbon.ntask.core.TaskManager.registerTask()

Examples of net.sourceforge.ganttproject.task.TaskManager.registerTask()

    }


    public void testAssignmentDisappearOnResourceDeletion() {
        TaskManager taskManager = getTaskManager();
        Task task = taskManager.createTask();
        taskManager.registerTask(task);
        ProjectResource res1 = getResourceManager().getById(1);
        task.getAssignmentCollection().addAssignment(res1);
        res1.delete();
        Set resources = extractResources(task);
        assertTrue("It is expecte that after resource deletion assignments disappear", resources.isEmpty());

View Full Code Here

Examples of org.apache.hama.bsp.sync.ZooKeeperSyncClientImpl.registerTask()


      int zkPort = BSPNetUtils.getFreePort(21815);
      configuration.setInt(Constants.PEER_PORT, zkPort);
      peerClient.init(configuration, jobID, task1);


      peerClient.registerTask(jobID, "hamanode1", 5000L, task1);
      peerClient.registerTask(jobID, "hamanode2", 5000L, task2);


      peerClient.storeInformation(
          peerClient.constructKey(jobID, "info", "level2"), new IntWritable(5),
          true, null);

View Full Code Here

Examples of org.apache.hama.bsp.sync.ZooKeeperSyncClientImpl.registerTask()

      int zkPort = BSPNetUtils.getFreePort(21815);
      configuration.setInt(Constants.PEER_PORT, zkPort);
      peerClient.init(configuration, jobID, task1);


      peerClient.registerTask(jobID, "hamanode1", 5000L, task1);
      peerClient.registerTask(jobID, "hamanode2", 5000L, task2);


      peerClient.storeInformation(
          peerClient.constructKey(jobID, "info", "level2"), new IntWritable(5),
          true, null);

View Full Code Here

Examples of org.apache.hama.bsp.sync.ZooKeeperSyncClientImpl.registerTask()


      int zkPort = BSPNetUtils.getFreePort(21815);
      configuration.setInt(Constants.PEER_PORT, zkPort);
      peerClient.init(configuration, jobID, task1);


      peerClient.registerTask(jobID, "hamanode1", 5000L, task1);
      peerClient.registerTask(jobID, "hamanode2", 5000L, task2);


      peerClient.storeInformation(
          peerClient.constructKey(jobID, "info", "level2"), new IntWritable(5),
          true, null);

View Full Code Here

Examples of org.apache.hama.bsp.sync.ZooKeeperSyncClientImpl.registerTask()

      int zkPort = BSPNetUtils.getFreePort(21815);
      configuration.setInt(Constants.PEER_PORT, zkPort);
      peerClient.init(configuration, jobID, task1);


      peerClient.registerTask(jobID, "hamanode1", 5000L, task1);
      peerClient.registerTask(jobID, "hamanode2", 5000L, task2);


      peerClient.storeInformation(
          peerClient.constructKey(jobID, "info", "level2"), new IntWritable(5),
          true, null);

View Full Code Here

Examples of org.apache.hama.bsp.sync.ZooKeeperSyncClientImpl.registerTask()


      int zkPort = BSPNetUtils.getFreePort(21815);
      configuration.setInt(Constants.PEER_PORT, zkPort);
      peerClient.init(configuration, jobID, task1);


      peerClient.registerTask(jobID, "hamanode1", 5000L, task1);
      peerClient.registerTask(jobID, "hamanode2", 5000L, task2);


      peerClient.storeInformation(
          peerClient.constructKey(jobID, "info", "level2"), new IntWritable(5),
          true, null);

View Full Code Here

Examples of org.apache.hama.bsp.sync.ZooKeeperSyncClientImpl.registerTask()

      int zkPort = BSPNetUtils.getFreePort(21815);
      configuration.setInt(Constants.PEER_PORT, zkPort);
      peerClient.init(configuration, jobID, task1);


      peerClient.registerTask(jobID, "hamanode1", 5000L, task1);
      peerClient.registerTask(jobID, "hamanode2", 5000L, task2);


      peerClient.storeInformation(
          peerClient.constructKey(jobID, "info", "level2"), new IntWritable(5),
          true, null);

View Full Code Here

Examples of org.wso2.carbon.ntask.core.TaskManager.registerTask()

            DeclarativeServiceReferenceHolder.getInstance().getConfigPub().getCron());
        taskInfo = new TaskInfo(
            CloudControllerConstants.TOPOLOGY_SYNC_TASK_NAME,
            TopologySynchronizerTask.class.getName(),
            new HashMap<String, String>(), triggerInfo);
        tm.registerTask(taskInfo);
      }


    } catch (Exception e) {
      String msg = "Error scheduling task: "
          + CloudControllerConstants.TOPOLOGY_SYNC_TASK_NAME;

View Full Code Here

Examples of org.wso2.carbon.ntask.core.TaskManager.registerTask()

                  .getDataPublisherCron());
          taskInfo = new TaskInfo(
              CloudControllerConstants.DATA_PUB_TASK_NAME,
              CartridgeInstanceDataPublisherTask.class.getName(),
              new HashMap<String, String>(), triggerInfo);
          tm.registerTask(taskInfo);


          // Following code is currently not required, due to an issue
          // in TS API.
          // tm.scheduleTask(taskInfo.getName());
        }

View Full Code Here

Examples of org.wso2.carbon.ntask.core.TaskManager.registerTask()

        String cron = cronProp != null ?  cronProp :CloudControllerConstants.TOPOLOGY_SYNC_CRON ;
                TaskInfo.TriggerInfo triggerInfo = new TaskInfo.TriggerInfo(cron);
                TaskInfo taskInfo = new TaskInfo(CloudControllerConstants.TOPOLOGY_SYNC_TASK_NAME,
                        TopologySynchronizerTask.class.getName(),
                        new HashMap<String, String>(), triggerInfo);
                taskManager.registerTask(taskInfo);
                if(log.isDebugEnabled()) {
                    log.debug(String.format("Topology synchronization task scheduled: %s", CloudControllerConstants.TOPOLOGY_SYNC_TASK_NAME));
                }
            }

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.