Examples of ManagedContextTimerTask


Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

      }
    }
  }
 
  private TimerTask getTimerTask() {
    return new ManagedContextTimerTask() {
            @Override
            protected void runInContext() {
        try {
          // doIdleCheck();
         
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

            }
        }
    }

    private TimerTask getTimerTask() {
        return new ManagedContextTimerTask() {
            @Override
            protected void runInContext() {
                try {
                    // doIdleCheck();
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

                logger.info("Startup properties is not found.");
        }
    }

    private TimerTask getHeartbeatTask() {
        return new ManagedContextTimerTask() {
            @Override
            protected void runInContext() {
                try {
                    mhost.setLastHeartbeatTime(DateHelper.currentGMTTime());
                    mhostDao.updateHeartBeat(mhost);
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

    @Override
    public boolean configure(String name, Map<String, Object> params)
            throws ConfigurationException {

        _messageBus.subscribe(AsyncJob.Topics.JOB_HEARTBEAT, MessageDispatcher.getDispatcher(this));
        _timer.scheduleAtFixedRate(new ManagedContextTimerTask() {
            @Override
            protected void runInContext() {
                heartbeat();
            }
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

            _testClockTimer = new Timer("TestClock");
            // Run the test clock every 60s. Because every tick is counted as 1 minute.
            // Else it becomes too confusing.
            _testClockTimer.schedule(_testTimerTask, 100 * 1000L, 60 * 1000L);
        } else {
            final TimerTask timerTask = new ManagedContextTimerTask() {
                @Override
                protected void runInContext() {
                    try {
                        final Date currentTimestamp = new Date();
                        poll(currentTimestamp);
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

      }
    }
  }
 
  private TimerTask getTimerTask() {
    return new ManagedContextTimerTask() {
            @Override
            protected void runInContext() {
        try {
          // doIdleCheck();
         
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

  @Override
  public boolean configure(String name, Map<String, Object> params)
      throws ConfigurationException {
   
        _messageBus.subscribe(AsyncJob.Topics.JOB_HEARTBEAT, MessageDispatcher.getDispatcher(this));
    _timer.scheduleAtFixedRate(new ManagedContextTimerTask() {
      @Override
      protected void runInContext() {
        heartbeat();
      }
     
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

                logger.info("Startup properties is not found.");
        }
    }

    private TimerTask getHeartbeatTask() {
        return new ManagedContextTimerTask() {
            @Override
            protected void runInContext() {
                try {
                    mhost.setLastHeartbeatTime(DateHelper.currentGMTTime());
                    mhostDao.updateHeartBeat(mhost);
View Full Code Here

Examples of org.apache.cloudstack.managed.context.ManagedContextTimerTask

            // Run the test clock every 60s. Because every tick is counted as 1 minute.
            // Else it becomes too confusing.
            _testClockTimer.schedule(_testTimerTask, 100*1000L, 60*1000L);
        }
        else {
            TimerTask timerTask = new ManagedContextTimerTask() {
                @Override
                protected void runInContext() {
                    try {
                        Date currentTimestamp = new Date();
                        poll(currentTimestamp);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.