diff --git a/akka-bbb-apps/src/main/scala/org/bigbluebutton/core/record/events/EndAndKickAllRecordEvent.scala b/akka-bbb-apps/src/main/scala/org/bigbluebutton/core/record/events/EndAndKickAllRecordEvent.scala index 6735734fbafe4f5558a9d4f8680989b528684ee4..267592b65988dc58962899955d7ceec5b231d5b9 100755 --- a/akka-bbb-apps/src/main/scala/org/bigbluebutton/core/record/events/EndAndKickAllRecordEvent.scala +++ b/akka-bbb-apps/src/main/scala/org/bigbluebutton/core/record/events/EndAndKickAllRecordEvent.scala @@ -20,5 +20,15 @@ package org.bigbluebutton.core.record.events class EndAndKickAllRecordEvent extends AbstractParticipantRecordEvent { + import EndAndKickAllRecordEvent._ + setEvent("EndAndKickAllEvent") + + def setReason(reason: String) { + eventMap.put(REASON, reason) + } +} + +object EndAndKickAllRecordEvent { + protected final val REASON = "reason" } \ No newline at end of file diff --git a/akka-bbb-apps/src/main/scala/org/bigbluebutton/endpoint/redis/RedisRecorderActor.scala b/akka-bbb-apps/src/main/scala/org/bigbluebutton/endpoint/redis/RedisRecorderActor.scala index 271cd0b8cbde116f7a47eb1c3f84f242b99aa67e..936499d4759b49d6edfde4f55fd235d1d35bd8e0 100755 --- a/akka-bbb-apps/src/main/scala/org/bigbluebutton/endpoint/redis/RedisRecorderActor.scala +++ b/akka-bbb-apps/src/main/scala/org/bigbluebutton/endpoint/redis/RedisRecorderActor.scala @@ -98,7 +98,7 @@ class RedisRecorderActor( case m: RecordingStatusChangedEvtMsg => handleRecordingStatusChangedEvtMsg(m) case m: RecordStatusResetSysMsg => handleRecordStatusResetSysMsg(m) case m: WebcamsOnlyForModeratorChangedEvtMsg => handleWebcamsOnlyForModeratorChangedEvtMsg(m) - case m: EndAndKickAllSysMsg => handleEndAndKickAllSysMsg(m) + case m: MeetingEndingEvtMsg => handleEndAndKickAllSysMsg(m) // Recording case m: RecordingChapterBreakSysMsg => handleRecordingChapterBreakSysMsg(m) @@ -484,10 +484,10 @@ class RedisRecorderActor( record(msg.header.meetingId, ev.toMap.asJava) } - private def handleEndAndKickAllSysMsg(msg: EndAndKickAllSysMsg): Unit = { + private def handleEndAndKickAllSysMsg(msg: MeetingEndingEvtMsg): Unit = { val ev = new EndAndKickAllRecordEvent() ev.setMeetingId(msg.header.meetingId) - + ev.setReason(msg.body.reason) record(msg.header.meetingId, ev.toMap.asJava) }