Package org.apache.oozie.service

Examples of org.apache.oozie.service.Services.destroy()

169
170
171
172
173
174
175
176
177
178
179
        UUIDService uuid = services.get(UUIDService.class);
        String id = uuid.generateId(ApplicationType.WORKFLOW);
        String childId = uuid.generateChildId(id, "a");
        assertEquals(id, uuid.getId(childId));
        assertEquals("a", uuid.getChildName(childId));
        services.destroy();

        setSystemProperty(UUIDService.CONF_GENERATOR, "random");
        services = new Services();
        services.init();
        uuid = services.get(UUIDService.class);
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
        uuid = services.get(UUIDService.class);
        id = uuid.generateId(ApplicationType.WORKFLOW);
        childId = uuid.generateChildId(id, "a");
        assertEquals(id, uuid.getId(childId));
        assertEquals("a", uuid.getChildName(childId));
        services.destroy();
    }

    /**
     * Test : kill job but failed to kill an already successful action.
     *
 
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
                    throw new IllegalStateException("original share lib doesn't exist");
                }
            }

            fs.copyFromLocalFile(false, srcPath, dstPath);
            services.destroy();
            FileUtils.deleteDirectory(temp);

            return 0;
        }
        catch (ParseException ex) {
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
            a.add("2009-06-24 02:43:13,958 DEBUG");
            a.add(" WorkflowRunnerCallable:323 - " + XLog.Info.get().createPrefix() + " test log");
            assertEquals(true, xf2.matches(a));
        }
        finally {
            services.destroy();
        }

        XLogStreamer.Filter.reset();
        XLogStreamer.Filter.defineParameter("USER");
        XLogStreamer.Filter.defineParameter("GROUP");
View Full Code Here
22
23
24
25
26
27
28
29
30
31
32
    public void testService() throws Exception {
        Services services = new Services();
        services.init();
        assertNotNull(services.get(ActionService.class));
        services.destroy();
    }

    public void testActions() throws Exception {
        Services services = new Services();
        services.init();
View Full Code Here
30
31
32
33
34
35
36
37
38
    public void testActions() throws Exception {
        Services services = new Services();
        services.init();
        ActionService as = services.get(ActionService.class);
        assertNotNull(as.getExecutor("switch"));
        services.destroy();
    }

}
View Full Code Here
28
29
30
31
32
33
34
35
        String prefix = XLog.Info.get().createPrefix();
        assertTrue(prefix.contains(DagXLogInfoService.TOKEN));
        assertTrue(prefix.contains(DagXLogInfoService.APP));
        assertTrue(prefix.contains(DagXLogInfoService.JOB));
        assertTrue(prefix.contains(DagXLogInfoService.ACTION));
        services.destroy();
    }
}
View Full Code Here
23
24
25
26
27
28
29
30
31
32
33
    public void testService() throws Exception {
        Services services = new Services();
        services.init();
        CallbackService cs = services.get(CallbackService.class);
        assertNotNull(cs);
        services.destroy();
    }

    public void testCallbacks() throws Exception {
        Services services = new Services();
        services.init();
View Full Code Here
38
39
40
41
42
43
44
45
46
        assertTrue(callback.contains("id=a"));
        assertTrue(callback.contains("status=@STATUS"));
        callback = callback.replace("@STATUS", "OK");
        assertEquals("a", cs.getActionId(callback));
        assertEquals("OK", cs.getExternalStatus(callback));
        services.destroy();
    }

}
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
            container.start();
            assertions.call();
        }
        finally {
            container.stop();
            services.destroy();
        }
    }

    public void testEmptyResources() {
        try {
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.