Package org.quartz

Examples of org.quartz.JobDataMap.containsKey()

104
105
106
107
108
109
110
111
112
113
114
        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
114
115
116
117
118
119
120
121
122
123
124
        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
118
119
120
121
122
123
124
125
126
127
128
        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);
        }
           
        Integer exitCode = this.runNativeCommand(command, parameters, wait, consumeStreams);
        context.setResult(exitCode);
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
            throw new JobExecutionException("FileScanListener named '" +
                    listenerName + "' not found in SchedulerContext");
        }
       
        long lastDate = -1;
        if(mergedJobDataMap.containsKey(LAST_MODIFIED_TIME)) {
            lastDate = mergedJobDataMap.getLong(LAST_MODIFIED_TIME);
        }
       
        long newDate = getLastModifiedDate(fileName);
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
        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
122
123
124
125
126
127
128
129
130
131
132
        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);
        }
           
        Integer exitCode = this.runNativeCommand(command, parameters, wait, consumeStreams);
        context.setResult(exitCode);
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
            throw new JobExecutionException("FileScanListener named '" +
                    listenerName + "' not found in SchedulerContext");
        }
       
        long lastDate = -1;
        if(mergedJobDataMap.containsKey(LAST_MODIFIED_TIME)) {
            lastDate = mergedJobDataMap.getLong(LAST_MODIFIED_TIME);
        }
       
        long newDate = getLastModifiedDate(fileName);
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
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.