1 |
|
|
2 |
|
|
3 |
|
|
4 |
|
|
5 |
|
|
6 |
|
|
7 |
|
|
8 |
|
|
9 |
|
|
10 |
|
|
11 |
|
|
12 |
|
|
13 |
|
|
14 |
|
|
15 |
|
|
16 |
|
package org.kuali.rice.ksb; |
17 |
|
|
18 |
|
import javax.xml.namespace.QName; |
19 |
|
|
20 |
|
import org.junit.Test; |
21 |
|
import org.kuali.rice.ksb.messaging.MessagingTestObject; |
22 |
|
import org.kuali.rice.ksb.messaging.resourceloader.KSBResourceLoaderFactory; |
23 |
|
import org.kuali.rice.ksb.messaging.service.KSBJavaService; |
24 |
|
import org.kuali.rice.ksb.service.KSBServiceLocator; |
25 |
|
import org.kuali.rice.ksb.test.KSBTestCase; |
26 |
|
|
27 |
|
|
|
|
| 0% |
Uncovered Elements: 7 (7) |
Complexity: 2 |
Complexity Density: 0.4 |
|
28 |
|
public class StartBusTest extends KSBTestCase { |
29 |
|
|
|
|
| 0% |
Uncovered Elements: 1 (1) |
Complexity: 1 |
Complexity Density: 1 |
|
30 |
0
|
@Override... |
31 |
|
public boolean startClient1() { |
32 |
0
|
return true; |
33 |
|
} |
34 |
|
|
|
|
| 0% |
Uncovered Elements: 4 (4) |
Complexity: 1 |
Complexity Density: 0.25 |
4
-
|
|
35 |
0
|
@Test... |
36 |
|
public void testStartTheBus() { |
37 |
0
|
QName serviceName = new QName("TestCl1", "testJavaAsyncService"); |
38 |
|
|
39 |
0
|
((Runnable)KSBResourceLoaderFactory.getRemoteResourceLocator()).run(); |
40 |
|
|
41 |
0
|
KSBJavaService testJavaAsyncService = (KSBJavaService) KSBServiceLocator.getMessageHelper().getServiceAsynchronously(serviceName); |
42 |
0
|
testJavaAsyncService.invoke(new MessagingTestObject("message content")); |
43 |
|
|
44 |
|
|
45 |
|
} |
46 |
|
|
47 |
|
|
48 |
|
|
49 |
|
|
50 |
|
|
51 |
|
|
52 |
|
|
53 |
|
|
54 |
|
|
55 |
|
|
56 |
|
} |