Package javax.ejb

Examples of javax.ejb.Timer.cancel()

90
91
92
93
94
95
96
97
98
99
100
            }
            Assert.assertTrue(SuspendTimerServiceBean.awaitTimerServiceCount() > 0);
        } finally {
            if (timer != null) {
                timer.cancel();
                Thread.sleep(100);
            }
        }
    }
View Full Code Here
131
132
133
134
135
136
137
138
139
140
141
            Thread.sleep(300); //if they were backed up we give them some time to run
            int timerServiceCount = SuspendTimerServiceBean.getTimerServiceCount();
            Assert.assertTrue("Interval " + (System.currentTimeMillis() - start) + " count " + timerServiceCount, timerServiceCount < 40);
        } finally {
            if (timer != null) {
                timer.cancel();
                Thread.sleep(100);
            }
        }
    }
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
            }
            Assert.assertEquals(1, SuspendTimerServiceBean.awaitTimerServiceCount());
        } finally {
            if (timer != null) {
                try {
                    timer.cancel();
                    Thread.sleep(100);
                } catch(Exception e) {
                    //as the timer has already expired this may throw an exception
                }
            }
View Full Code Here
217
218
219
220
221
222
223
224
225
226
227
        Collection<Timer> timers = timer.getTimers();
        // stop all timers
        boolean cancelled = false;
        for(Iterator<Timer> it = timers.iterator(); it.hasNext(); ) {
            Timer t = it.next();
            t.cancel();
            cancelled = true;
            log.info("Stopped snapshot timer...");
        }
        return cancelled;
    }
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
  @PreDestroy
  public void initClear() {
    LOG.info("Clear Timers ");
    for (Object obj : timerService.getTimers()) {
      Timer t = (Timer) obj;
      t.cancel();
    }
  }

  public void createTimers() {
    // create timer
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
    LOG.info("Clear Timers ");
    if (timerService.getTimers() != null) {
      LOG.info("Size: {}", timerService.getTimers().size());
      for (Object obj : timerService.getTimers()) {
        Timer t = (Timer) obj;
        t.cancel();
      }
    }
  }
 
  public void createTimers() {
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
  @PreDestroy
  public void initClear() {
    LOG.info("Clear Timers ");
    for (Object obj : timerService.getTimers()) {
      Timer t = (Timer) obj;
      t.cancel();
    }
  }
 
  public void createTimers() {
    /**
 
View Full Code Here
257
258
259
260
261
262
263
264
265
266
267
        Collection<Timer> timers = timer.getTimers();
        // stop all timers
        boolean cancelled = false;
        for(Iterator<Timer> it = timers.iterator(); it.hasNext(); ) {
            Timer t = it.next();
            t.cancel();
            cancelled = true;
            log.info("Stopped snapshot timer...");
        }
        return cancelled;
    }
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.