Examples of TimerImpl

com.sogou.qadev.service.cynthia.bean.impl.TimerImpl
@description :timer implements @author :liming @mail :liming@sogou-inc.com @date :2014-5-6 下午4:54:58 @version :v1.0
org.jboss.as.ejb3.timerservice.TimerImpl
Implementation of EJB3.1 {@link Timer} @author Carlo de Wolf @version $Revision: $
org.jboss.ejb.txtimer.TimerImpl
An implementation of an EJB Timer. Internally it uses a java.util.Timer and maintains its state in a Tx manner. @author Thomas.Diesler@jboss.org @author Dimitris.Andreadis@jboss.org @version $Revision: 102438 $ @since 07-Apr-2004
org.jbpm.pvm.internal.job.TimerImpl
a runtime timer instance.
Timers can be
@author Tom Baeyens @author Pascal Verdage @author Alejandro Guizar
org.openhab.model.script.internal.actions.TimerImpl
This is an implementation of the {@link Timer} interface using the Quartzlibrary for scheduling. @author Kai Kreuzer @since 1.0.0

Examples of com.sogou.qadev.service.cynthia.bean.impl.TimerImpl

   */
  public Timer createTimer(String createUser)
  {
    UUID id = DataAccessFactory.getInstance().newUUID("TIME");
    Timestamp createTime = new Timestamp(System.currentTimeMillis());
    return new TimerImpl(id, createUser, createTime);
  }

View Full Code Here

Examples of com.sogou.qadev.service.cynthia.bean.impl.TimerImpl

      while(rst.next())
      {
        UUID id = DataAccessFactory.getInstance().createUUID(rst.getObject("id").toString());
        Timestamp createTime = rst.getTimestamp("create_time");


        Timer timer = new TimerImpl(id, createUser, createTime);


        timer.setName(rst.getString("name"));
        timer.setActionId(DataAccessFactory.getInstance().createUUID(rst.getObject("action_id").toString()));
        timer.setActionParam(rst.getString("action_param"));
        timer.setYear(rst.getString("year"));
        timer.setMonth(rst.getString("month"));
        timer.setWeek(rst.getString("week"));
        timer.setDay(rst.getString("day"));
        timer.setHour(rst.getString("hour"));
        timer.setMinute(rst.getString("minute"));
        timer.setSecond(rst.getString("second"));
        timer.setStart(rst.getBoolean("is_start"));


        Object filterIdObj = rst.getObject("filter_id");
        if(filterIdObj != null)
          timer.setFilterId(DataAccessFactory.getInstance().createUUID(filterIdObj.toString()));


        Object statisticerIdObj = rst.getObject("statisticer_id");
        if(statisticerIdObj != null)
          timer.setStatisticerId(DataAccessFactory.getInstance().createUUID(statisticerIdObj.toString()));


        timer.setRetryAccount(rst.getLong("retry_account"));
        timer.setRetryDelay(rst.getLong("retry_delay"));
        timer.setSendNull(rst.getBoolean("is_send_null"));


        timerSet.add(timer);
      }
    }
    catch(Exception e)

View Full Code Here

Examples of com.sogou.qadev.service.cynthia.bean.impl.TimerImpl

      {
        UUID id = DataAccessFactory.getInstance().createUUID(rst.getObject("id").toString());
        String createUser = rst.getString("create_user");
        Timestamp createTime = rst.getTimestamp("create_time");


        Timer timer = new TimerImpl(id, createUser, createTime);


        timer.setName(rst.getString("name"));
        timer.setActionId(DataAccessFactory.getInstance().createUUID(rst.getObject("action_id").toString()));
        timer.setActionParam(rst.getString("action_param"));
        timer.setYear(rst.getString("year"));
        timer.setMonth(rst.getString("month"));
        timer.setWeek(rst.getString("week"));
        timer.setDay(rst.getString("day"));
        timer.setHour(rst.getString("hour"));
        timer.setMinute(rst.getString("minute"));
        timer.setSecond(rst.getString("second"));
        timer.setStart(rst.getBoolean("is_start"));


        Object filterIdObj = rst.getObject("filter_id");
        if(filterIdObj != null)
          timer.setFilterId(DataAccessFactory.getInstance().createUUID(filterIdObj.toString()));


        Object statisticerIdObj = rst.getObject("statisticer_id");
        if(statisticerIdObj != null)
          timer.setStatisticerId(DataAccessFactory.getInstance().createUUID(statisticerIdObj.toString()));


        timer.setRetryAccount(rst.getLong("retry_account"));
        timer.setRetryDelay(rst.getLong("retry_delay"));
        timer.setSendNull(rst.getBoolean("is_send_null"));


        timerSet.add(timer);
      }
    }
    catch(Exception e)

View Full Code Here

Examples of com.sogou.qadev.service.cynthia.bean.impl.TimerImpl

      {
        UUID id = DataAccessFactory.getInstance().createUUID(rst.getObject("id").toString());
        Timestamp createTime = rst.getTimestamp("create_time");
        String createUser = rst.getString("create_user");


        Timer timer = new TimerImpl(id, createUser, createTime);


        timer.setName(rst.getString("name"));
        timer.setActionId(DataAccessFactory.getInstance().createUUID(rst.getObject("action_id").toString()));
        timer.setActionParam(rst.getString("action_param"));
        timer.setYear(rst.getString("year"));
        timer.setMonth(rst.getString("month"));
        timer.setWeek(rst.getString("week"));
        timer.setDay(rst.getString("day"));
        timer.setHour(rst.getString("hour"));
        timer.setMinute(rst.getString("minute"));
        timer.setSecond(rst.getString("second"));
        timer.setStart(rst.getBoolean("is_start"));


        Object filterIdObj = rst.getObject("filter_id");
        if(filterIdObj != null)
          timer.setFilterId(DataAccessFactory.getInstance().createUUID(filterIdObj.toString()));


        Object statisticerIdObj = rst.getObject("statisticer_id");
        if(statisticerIdObj != null)
          timer.setStatisticerId(DataAccessFactory.getInstance().createUUID(statisticerIdObj.toString()));


        timer.setRetryAccount(rst.getLong("retry_account"));
        timer.setRetryDelay(rst.getLong("retry_delay"));
        timer.setSendNull(rst.getBoolean("is_send_null"));


        timerSet.add(timer);
      }
    }
    catch(Exception e)

View Full Code Here

Examples of com.sogou.qadev.service.cynthia.bean.impl.TimerImpl

      if(rst.next())
      {
        String createUser = rst.getString("create_user");
        Timestamp createTime = rst.getTimestamp("create_time");


        timer = new TimerImpl(timerId, createUser, createTime);
        timer.setName(rst.getString("name"));
        timer.setActionId(DataAccessFactory.getInstance().createUUID(rst.getObject("action_id").toString()));
        timer.setActionParam(rst.getString("action_param"));
        timer.setYear(rst.getString("year"));
        timer.setMonth(rst.getString("month"));

View Full Code Here

Examples of com.sogou.qadev.service.cynthia.bean.impl.TimerImpl

      {
        UUID id = DataAccessFactory.getInstance().createUUID(rst.getObject("id").toString());
        String createUser = rst.getString("create_user");
        Timestamp createTime = rst.getTimestamp("create_time");


        Timer timer = new TimerImpl(id, createUser, createTime);


        timer.setName(rst.getString("name"));
        timer.setActionId(DataAccessFactory.getInstance().createUUID(rst.getObject("action_id").toString()));
        timer.setActionParam(rst.getString("action_param"));
        timer.setYear(rst.getString("year"));
        timer.setMonth(rst.getString("month"));
        timer.setWeek(rst.getString("week"));
        timer.setDay(rst.getString("day"));
        timer.setHour(rst.getString("hour"));
        timer.setMinute(rst.getString("minute"));
        timer.setSecond(rst.getString("second"));
        timer.setStart(rst.getBoolean("is_start"));


        Object filterIdObj = rst.getObject("filter_id");
        if(filterIdObj != null)
          timer.setFilterId(DataAccessFactory.getInstance().createUUID(filterIdObj.toString()));


        Object statisticerIdObj = rst.getObject("statisticer_id");
        if(statisticerIdObj != null)
          timer.setStatisticerId(DataAccessFactory.getInstance().createUUID(statisticerIdObj.toString()));


        timer.setRetryAccount(rst.getLong("retry_account"));
        timer.setRetryDelay(rst.getLong("retry_delay"));
        timer.setSendNull(rst.getBoolean("is_send_null"));


        timerSet.add(timer);
      }
    }
    catch(Exception e)

View Full Code Here

Examples of org.jboss.as.ejb3.timerservice.TimerImpl

     */
    public void removeAllTimers() {
        //cancel all timers for this entity
        for (final Timer timer : getComponent().getTimerService().getTimers()) {
            if (timer instanceof TimerImpl) {
                TimerImpl timerImpl = (TimerImpl) timer;
                if (timerImpl.getPrimaryKey() != null && timerImpl.getPrimaryKey().equals(getPrimaryKey())) {
                    timer.cancel();
                }
            }
        }
    }

View Full Code Here

Examples of org.jboss.as.ejb3.timerservice.TimerImpl

            statement.setString(2, partition);
            resultSet = statement.executeQuery();
            final List<TimerImpl> timers = new ArrayList<TimerImpl>();
            while (resultSet.next()) {
                try {
                    final TimerImpl timerImpl = timerFromResult(resultSet, timerService);
                    if (timerImpl != null) {
                        timers.add(timerImpl);
                    }
                } catch (Exception e) {
                    EjbLogger.ROOT_LOGGER.timerReinstatementFailed(resultSet.getString(2), resultSet.getString(1), e);

View Full Code Here

Examples of org.jboss.as.ejb3.timerservice.TimerImpl

                                    String id = resultSet.getString(1);
                                    if (!existing.remove(id)) {
                                        synchronized (DatabaseTimerPersistence.this) {
                                            knownTimerIds.get(timedObjectId).add(id);
                                        }
                                        final TimerImpl timerImpl = timerFromResult(resultSet, listener.getTimerService());
                                        listener.timerAdded(timerImpl);
                                    }
                                } catch (Exception e) {
                                    EjbLogger.ROOT_LOGGER.timerReinstatementFailed(resultSet.getString(2), resultSet.getString(1), e);
                                }

View Full Code Here

Examples of org.jboss.as.ejb3.timerservice.TimerImpl

            if (status == Status.STATUS_UNKNOWN ||
                    status == Status.STATUS_NO_TRANSACTION) {
                return timerImpl;
            }
            final String key = timerTransactionKey(timerImpl);
            TimerImpl existing = (TimerImpl) transactionSynchronizationRegistry.getValue().getResource(key);
            return existing != null ? existing : timerImpl;
        } catch (SystemException e) {
            throw new RuntimeException(e);
        }
    }

View Full Code Here

0 1 2

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.