You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openmeetings.apache.org by so...@apache.org on 2014/10/12 15:12:56 UTC
svn commit: r1631172 -
/openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/remote/ChatService.java
Author: solomax
Date: Sun Oct 12 13:12:56 2014
New Revision: 1631172
URL: http://svn.apache.org/r1631172
Log:
Send chat message from mobile is implemented
Modified:
openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/remote/ChatService.java
Modified: openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/remote/ChatService.java
URL: http://svn.apache.org/viewvc/openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/remote/ChatService.java?rev=1631172&r1=1631171&r2=1631172&view=diff
==============================================================================
--- openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/remote/ChatService.java (original)
+++ openmeetings/branches/3.0.x/src/main/java/org/apache/openmeetings/remote/ChatService.java Sun Oct 12 13:12:56 2014
@@ -90,6 +90,24 @@ public class ChatService implements IPen
return str_h+':'+str_m;
}
+ public void sendChatMessage(String message) {
+ IConnection current = Red5.getConnectionLocal();
+ Client client = sessionManager.getClientByStreamId(current.getClient().getId(), null);
+ List<String> msg = new ArrayList<String>();
+ msg.add("chat"); //'privatechat'
+ msg.add(""); //date-time
+ msg.add("newtextmessage");
+ msg.add(client.getUsername());
+ msg.add(message);
+ msg.add(client.getUsercolor());
+ msg.add(client.getPublicSID()); //om[6] = parent.parent.isPrivate ? parent.parent.parent.refObj.publicSID : canvas.publicSID;
+ msg.add("false");// canvas.isrtl;
+ msg.add("" + client.getUser_id());
+ Room room = roomDao.get(client.getRoom_id());
+ msg.add("" + (room.getChatModerated() && !(client.getIsMod() || client.getIsSuperModerator())));
+ sendMessageWithClient(msg);
+ }
+
/**
* sends a Chat-Message
* to all members of the Chatroom
@@ -102,7 +120,7 @@ public class ChatService implements IPen
public int sendMessageWithClient(Object newMessage) {
try {
IConnection current = Red5.getConnectionLocal();
- Client currentClient = this.sessionManager.getClientByStreamId(current.getClient().getId(), null);
+ Client currentClient = sessionManager.getClientByStreamId(current.getClient().getId(), null);
Long room_id = currentClient.getRoom_id();
log.debug("room_id: " + room_id);