@@ -21,14 +21,13 @@ public class WorkflowTest extends AbstractContainerBaseTest {
21
21
@ Before
22
22
public void before () throws SpawnException {
23
23
joeActorRef = spawnSystem .createActorRef (
24
- ActorIdentity .of (spawnSystemName , "joe " ));
24
+ ActorIdentity .of (spawnSystemName , "JoeActor " ));
25
25
}
26
26
27
27
@ Test
28
28
public void testBroadcastBuilder () {
29
29
Broadcast broadcast = Broadcast .to ("test.channel" , "hi" , Actor .Request .getDefaultInstance ());
30
30
final Protocol .Broadcast protocolBroadcast = broadcast .build ();
31
- assertEquals ("hi" , protocolBroadcast .getChannelGroup ());
32
31
assertEquals ("test.channel" , protocolBroadcast .getChannelGroup ());
33
32
assertNotNull (protocolBroadcast .getValue ());
34
33
}
@@ -38,15 +37,15 @@ public void testForwardBuilder() throws Exception {
38
37
Forward forward = Forward .to (joeActorRef , "hi" );
39
38
final Protocol .Forward protocolForward = forward .build ();
40
39
assertEquals ("hi" , protocolForward .getActionName ());
41
- assertEquals ("joe " , protocolForward .getActor ());
40
+ assertEquals ("JoeActor " , protocolForward .getActor ());
42
41
}
43
42
44
43
@ Test
45
44
public void testPipeBuilder () throws Exception {
46
45
Pipe pipe = Pipe .to (joeActorRef , "hi" );
47
46
final Protocol .Pipe protocolPipe = pipe .build ();
48
47
assertEquals ("hi" , protocolPipe .getActionName ());
49
- assertEquals ("joe " , protocolPipe .getActor ());
48
+ assertEquals ("JoeActor " , protocolPipe .getActor ());
50
49
}
51
50
52
51
@ Test
@@ -56,6 +55,6 @@ public void testSideEffectBuilder() throws Exception {
56
55
Protocol .InvocationRequest request = protocolSideEffect .getRequest ();
57
56
assertNotNull (request );
58
57
assertEquals ("hi" , request .getActionName ());
59
- assertEquals ("joe " , request .getActor ().getId ().getName ());
58
+ assertEquals ("JoeActor " , request .getActor ().getId ().getName ());
60
59
}
61
60
}
0 commit comments