ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-server: SingleStreamRecordingService connect endpoint after storing in map

pull/391/head
pabloFuente 2020-02-02 00:42:33 +01:00
parent c8ca6b3805
commit fac8693e2f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
openvidu-server/src/main/java/io/openvidu/server/recording/service/SingleStreamRecordingService.java
View File

@ -251,8 +251,6 @@ public class SingleStreamRecordingService extends RecordingService {
} }
}); });
connectAccordingToProfile(kurentoParticipant.getPublisher(), recorder, profile);
RecorderEndpointWrapper wrapper = new RecorderEndpointWrapper(recorder, participant.getParticipantPublicId(), RecorderEndpointWrapper wrapper = new RecorderEndpointWrapper(recorder, participant.getParticipantPublicId(),
recordingId, participant.getPublisherStreamId(), participant.getClientMetadata(), recordingId, participant.getPublisherStreamId(), participant.getClientMetadata(),
participant.getServerMetadata(), kurentoParticipant.getPublisher().getMediaOptions().hasAudio(), participant.getServerMetadata(), kurentoParticipant.getPublisher().getMediaOptions().hasAudio(),
@ -261,6 +259,8 @@ public class SingleStreamRecordingService extends RecordingService {
activeRecorders.get(session.getSessionId()).put(participant.getPublisherStreamId(), wrapper); activeRecorders.get(session.getSessionId()).put(participant.getPublisherStreamId(), wrapper);
storedRecorders.get(session.getSessionId()).put(participant.getPublisherStreamId(), wrapper); storedRecorders.get(session.getSessionId()).put(participant.getPublisherStreamId(), wrapper);
connectAccordingToProfile(kurentoParticipant.getPublisher(), recorder, profile);
wrapper.getRecorder().record(); wrapper.getRecorder().record();
} }