Package org.quartz

Examples of org.quartz.JobDataMap.containsKey()

106
107
108
109
110
111
112
113
114
115
116
        triggerDataMap.put(EjbTimeoutJob.TIMER_DATA, data);

        final byte[] serial = serialize(triggerDataMap);
        final JobDataMap map = (JobDataMap) deserialize(serial);
        assertTrue(map.containsKey(EjbTimeoutJob.EJB_TIMERS_SERVICE));
        assertTrue(map.containsKey(EjbTimeoutJob.TIMER_DATA));
    }

    private static Object deserialize(final byte[] serial) throws Exception {
        final ByteArrayInputStream bais = new ByteArrayInputStream(serial);
        final ObjectInputStream ois = new ObjectInputStream(bais);
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
        triggerDataMap.put(EjbTimeoutJob.EJB_TIMERS_SERVICE, timerService);
        triggerDataMap.put(EjbTimeoutJob.TIMER_DATA, data);

        final byte[] serial = serialize(triggerDataMap);
        final JobDataMap map = (JobDataMap) deserialize(serial);
        assertTrue(map.containsKey(EjbTimeoutJob.EJB_TIMERS_SERVICE));
        assertTrue(map.containsKey(EjbTimeoutJob.TIMER_DATA));
    }

    private static Object deserialize(final byte[] serial) throws Exception {
        final ByteArrayInputStream bais = new ByteArrayInputStream(serial);
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
        triggerDataMap.put(EjbTimeoutJob.TIMER_DATA, data);

        final byte[] serial = serialize(triggerDataMap);
        final JobDataMap map = (JobDataMap) deserialize(serial);
        assertTrue(map.containsKey(EjbTimeoutJob.EJB_TIMERS_SERVICE));
        assertTrue(map.containsKey(EjbTimeoutJob.TIMER_DATA));
    }

    private static Object deserialize(final byte[] serial) throws Exception {
        final ByteArrayInputStream bais = new ByteArrayInputStream(serial);
        final ObjectInputStream ois = new ObjectInputStream(bais);
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
/* 110 */     if (parameters == null) {
/* 111 */       parameters = "";
/*     */     }
/*     */
/* 114 */     boolean wait = true;
/* 115 */     if (data.containsKey("waitForProcess")) {
/* 116 */       wait = data.getBooleanValue("waitForProcess");
/*     */     }
/* 118 */     boolean consumeStreams = false;
/* 119 */     if (data.containsKey("consumeStreams")) {
/* 120 */       consumeStreams = data.getBooleanValue("consumeStreams");
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
/* 114 */     boolean wait = true;
/* 115 */     if (data.containsKey("waitForProcess")) {
/* 116 */       wait = data.getBooleanValue("waitForProcess");
/*     */     }
/* 118 */     boolean consumeStreams = false;
/* 119 */     if (data.containsKey("consumeStreams")) {
/* 120 */       consumeStreams = data.getBooleanValue("consumeStreams");
/*     */     }
/*     */
/* 123 */     runNativeCommand(command, parameters, wait, consumeStreams);
/*     */   }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
/*  81 */     if (listener == null) {
/*  82 */       throw new JobExecutionException("FileScanListener named '" + listenerName + "' not found in SchedulerContext");
/*     */     }
/*     */
/*  85 */     long lastDate = -1L;
/*  86 */     if (data.containsKey(LAST_MODIFIED_TIME)) {
/*  87 */       lastDate = data.getLong(LAST_MODIFIED_TIME);
/*     */     }
/*  89 */     long newDate = getLastModifiedDate(fileName);
/*     */
/*  91 */     if (newDate < 0L) {
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
        if (parameters == null) {
            parameters = "";
        }

        boolean wait = true;
        if(data.containsKey(PROP_WAIT_FOR_PROCESS)) {
            wait = data.getBooleanValue(PROP_WAIT_FOR_PROCESS);
        }
        boolean consumeStreams = false;
        if(data.containsKey(PROP_CONSUME_STREAMS)) {
            consumeStreams = data.getBooleanValue(PROP_CONSUME_STREAMS);
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
        boolean wait = true;
        if(data.containsKey(PROP_WAIT_FOR_PROCESS)) {
            wait = data.getBooleanValue(PROP_WAIT_FOR_PROCESS);
        }
        boolean consumeStreams = false;
        if(data.containsKey(PROP_CONSUME_STREAMS)) {
            consumeStreams = data.getBooleanValue(PROP_CONSUME_STREAMS);
        }
           
        this.runNativeCommand(command, parameters, wait, consumeStreams);
    }
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
        if(listener == null)
            throw new JobExecutionException("FileScanListener named '" +
                    listenerName + "' not found in SchedulerContext");
       
        long lastDate = -1;
        if(data.containsKey(LAST_MODIFIED_TIME))
            lastDate = data.getLong(LAST_MODIFIED_TIME);
       
        long newDate = getLastModifiedDate(fileName);

        if(newDate < 0) {
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
        triggerDataMap.put(EjbTimeoutJob.EJB_TIMERS_SERVICE, timerService);
        triggerDataMap.put(EjbTimeoutJob.TIMER_DATA, data);

        final byte[] serial = serialize(triggerDataMap);
        final JobDataMap map = (JobDataMap) deserialize(serial);
        assertTrue(map.containsKey(EjbTimeoutJob.EJB_TIMERS_SERVICE));
        assertTrue(map.containsKey(EjbTimeoutJob.TIMER_DATA));
    }

    private static Object deserialize(final byte[] serial) throws Exception {
        final ByteArrayInputStream bais = new ByteArrayInputStream(serial);
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.