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.api.KsbApiServiceLocator;
22 import org.kuali.rice.ksb.messaging.MessagingTestObject;
23 import org.kuali.rice.ksb.messaging.service.KSBJavaService;
24 import org.kuali.rice.ksb.test.KSBTestCase;
25
26 public class StartBusTest extends KSBTestCase {
27
28 @Override
29 public boolean startClient1() {
30 return true;
31 }
32
33 @Test
34 public void testStartTheBus() {
35 QName serviceName = new QName("TestCl1", "testJavaAsyncService");
36
37 KsbApiServiceLocator.getServiceBus().synchronize();
38
39 KSBJavaService testJavaAsyncService = (KSBJavaService) KsbApiServiceLocator.getMessageHelper().getServiceAsynchronously(serviceName);
40 testJavaAsyncService.invoke(new MessagingTestObject("message content"));
41
42 }
43
44 }