Commit 0605955f authored by Dele Olajide's avatar Dele Olajide Committed by dele

Rayo plugin - Added start/stop speaking messages to MUC message thread

git-svn-id: http://svn.igniterealtime.org/svn/repos/openfire/trunk@13870 b35dd754-fafc-0310-a699-88a17e54d16e
parent 5cec4267
...@@ -1034,11 +1034,11 @@ public class RayoComponent extends AbstractComponent ...@@ -1034,11 +1034,11 @@ public class RayoComponent extends AbstractComponent
{ {
String recording = mixer + "-" + System.currentTimeMillis() + ".au"; String recording = mixer + "-" + System.currentTimeMillis() + ".au";
conferenceManager.recordConference(true, recording, "au"); conferenceManager.recordConference(true, recording, "au");
sendMucMessage(mixer, recording, iq.getFrom(), "Started voice recording"); sendMucMessage(mixer, recording, iq.getFrom(), "started voice recording");
} }
} }
sendMucMessage(mixer, null, iq.getFrom(), "Joined voice conversation"); sendMucMessage(mixer, null, iq.getFrom(), iq.getFrom().getNode() + " joined voice conversation");
} catch (ParseException pe) { // colibri joining as first participant } catch (ParseException pe) { // colibri joining as first participant
...@@ -1046,7 +1046,7 @@ public class RayoComponent extends AbstractComponent ...@@ -1046,7 +1046,7 @@ public class RayoComponent extends AbstractComponent
ConferenceManager conferenceManager = ConferenceManager.getConference(mixer, "PCM/48000/2", mixer, false); ConferenceManager conferenceManager = ConferenceManager.getConference(mixer, "PCM/48000/2", mixer, false);
String recording = mixer + "-" + System.currentTimeMillis() + ".au"; String recording = mixer + "-" + System.currentTimeMillis() + ".au";
conferenceManager.recordConference(true, recording, "au"); conferenceManager.recordConference(true, recording, "au");
sendMucMessage(mixer, recording, iq.getFrom(), "Started voice recording"); sendMucMessage(mixer, recording, iq.getFrom(), "started voice recording");
attachVideobridge(mixer, iq.getFrom(), "PCM/48000/2"); attachVideobridge(mixer, iq.getFrom(), "PCM/48000/2");
...@@ -1087,11 +1087,11 @@ public class RayoComponent extends AbstractComponent ...@@ -1087,11 +1087,11 @@ public class RayoComponent extends AbstractComponent
if (conferenceManager.getMemberList().size() == 1) if (conferenceManager.getMemberList().size() == 1)
{ {
conferenceManager.recordConference(false, null, null); conferenceManager.recordConference(false, null, null);
sendMucMessage(mixer, null, iq.getFrom(), "Stopped voice recording"); sendMucMessage(mixer, null, iq.getFrom(), "stopped voice recording");
detachVideobridge(mixer); detachVideobridge(mixer);
} }
sendMucMessage(mixer, null, iq.getFrom(), "Left voice conversation"); sendMucMessage(mixer, null, iq.getFrom(), iq.getFrom().getNode() + " left voice conversation");
} catch (Exception e) { } catch (Exception e) {
reply.setError(PacketError.Condition.item_not_found); reply.setError(PacketError.Condition.item_not_found);
...@@ -1530,6 +1530,8 @@ public class RayoComponent extends AbstractComponent ...@@ -1530,6 +1530,8 @@ public class RayoComponent extends AbstractComponent
ConferenceManager conferenceManager = ConferenceManager.findConferenceManager(conferenceId); ConferenceManager conferenceManager = ConferenceManager.findConferenceManager(conferenceId);
ArrayList memberList = conferenceManager.getMemberList(); ArrayList memberList = conferenceManager.getMemberList();
sendMucMessage(conferenceId, null, from, from.getNode() + (startSpeaking ? "started" : "stopped") + " speaking");
synchronized (memberList) synchronized (memberList)
{ {
for (int i = 0; i < memberList.size(); i++) for (int i = 0; i < memberList.size(); i++)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment