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

openvidu-server: fix some style for CDREventSendMessage

pull/402/head
Bruno Bottazzini 2020-03-06 09:38:14 +01:00
parent a7a54ddc64
commit 658f74ff7d
2 changed files with 0 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
openvidu-server/src/main/java/io/openvidu/server/cdr/CDREventSendMessage.java
View File

@ -10,29 +10,18 @@ public class CDREventSendMessage extends CDREvent {
private Participant participant; private Participant participant;
private JsonObject message; private JsonObject message;
public CDREventSendMessage(Participant participant, JsonObject message, Long timeStamp) { public CDREventSendMessage(Participant participant, JsonObject message, Long timeStamp) {
super(CDREventName.messageSent, participant.getSessionId() , timeStamp); super(CDREventName.messageSent, participant.getSessionId() , timeStamp);
this.participant = participant; this.participant = participant;
this.message = message; this.message = message;
// TODO Auto-generated constructor stub
} }
@Override @Override
public JsonObject toJson() { public JsonObject toJson() {
// TODO Auto-generated method stub
JsonObject json = super.toJson(); JsonObject json = super.toJson();
json.addProperty("participantId", this.participant.getParticipantPublicId()); json.addProperty("participantId", this.participant.getParticipantPublicId());
json.addProperty("data", message.get("data").getAsString()); json.addProperty("data", message.get("data").getAsString());
json.addProperty("type", message.get("type").getAsString()); json.addProperty("type", message.get("type").getAsString());
return json; return json;
} }
} }

1
openvidu-server/src/main/java/io/openvidu/server/core/SessionEventsHandler.java
View File

@ -374,7 +374,6 @@ public class SessionEventsHandler {
CDR.recordSendMessage(participant, message, transactionId); CDR.recordSendMessage(participant, message, transactionId);
rpcNotificationService.sendResponse(participant.getParticipantPrivateId(), transactionId, new JsonObject()); rpcNotificationService.sendResponse(participant.getParticipantPrivateId(), transactionId, new JsonObject());
} }
} }
public void onStreamPropertyChanged(Participant participant, Integer transactionId, Set<Participant> participants, public void onStreamPropertyChanged(Participant participant, Integer transactionId, Set<Participant> participants,