@@ -222,7 +222,7 @@ public void testStreamPlayParameters() {
222222
223223 webRTCClient .play (streamId , token , null , subscriberId , subscriberCode , viewerInfo );
224224
225- verify (wsHandler , times (1 )).startPlay (streamId , token , null , subscriberId , subscriberCode , viewerInfo );
225+ verify (wsHandler , times (1 )).startPlay (streamId , token , null , subscriberId , "" , subscriberCode , viewerInfo , false );
226226
227227 ArgumentCaptor <String > jsonCaptor = ArgumentCaptor .forClass (String .class );
228228 verify (wsHandler , times (1 )).sendTextMessage (jsonCaptor .capture ());
@@ -324,7 +324,7 @@ public void testJoinRoomParameters() {
324324 , "" , "" , "" , roomName );
325325
326326 webRTCClient .joinToConferenceRoom (roomName );
327- verify (wsHandler , timeout (1000 )).startPlay (roomName , "" , null , "" , "" , "" );
327+ verify (wsHandler , timeout (1000 )).startPlay (roomName , "" , null , "" , "" , "" , "" , false );
328328
329329 ArgumentCaptor <String > jsonCaptor = ArgumentCaptor .forClass (String .class );
330330 verify (wsHandler , times (2 )).sendTextMessage (jsonCaptor .capture ());
@@ -706,7 +706,7 @@ public void testWSAndListenerMessages() {
706706 , "" , "" , "" , room );
707707
708708 webRTCClient .joinToConferenceRoom (room );
709- verify (wsHandler , timeout (1000 )).startPlay (room , "" , null , "" , "" , "" );
709+ verify (wsHandler , timeout (1000 )).startPlay (room , "" , null , "" , "" , "" , "" , false );
710710
711711 webRTCClient .leaveFromConference (room );
712712 verify (wsHandler , timeout (1000 )).stop (streamId );
@@ -1162,15 +1162,15 @@ public void tesHandlePublishPlayRequestWhenWSNotConnected() {
11621162
11631163 String player1 = "player1" ;
11641164 webRTCClient .play (player1 );
1165- verify (wsHandler , never ()).startPlay (anyString (), anyString (), any (String [].class ), anyString (), anyString (), anyString ());
1165+ verify (wsHandler , never ()).startPlay (anyString (), anyString (), any (String [].class ), anyString (), anyString (), anyString (), anyString (), anyBoolean () );
11661166
11671167 assertEquals (2 , webRTCClient .getPeersForTest ().size ());
11681168 WebRTCClient .PeerInfo playPeer = webRTCClient .getPeersForTest ().get (player1 );
11691169 assertEquals (player1 , playPeer .id );
11701170
11711171 webRTCClient .onWebSocketConnected ();
11721172 verify (wsHandler , times (1 )).startPublish (eq (publishPeer .id ), anyString (), anyBoolean (), anyBoolean (), anyString (), anyString (), anyString (), anyString ());
1173- verify (wsHandler , times (1 )).startPlay (eq (playPeer .id ), anyString (), any (String [].class ), anyString (), anyString (), anyString ());
1173+ verify (wsHandler , times (1 )).startPlay (eq (playPeer .id ), anyString (), any (String [].class ), anyString (), anyString (), anyString (), anyString (), anyBoolean () );
11741174
11751175 }
11761176
0 commit comments