2525import org .red5 .logging .Red5LoggerFactory ;
2626import org .red5 .server .adapter .IApplication ;
2727import org .red5 .server .adapter .MultiThreadedApplicationAdapter ;
28+ import org .red5 .server .api .IClient ;
2829import org .red5 .server .api .IConnection ;
2930import org .red5 .server .api .IContext ;
3031import org .red5 .server .api .scope .IScope ;
@@ -40,98 +41,132 @@ public class BigBlueButtonApplication extends MultiThreadedApplicationAdapter {
4041 private RecorderApplication recorderApplication ;
4142 private AbstractApplicationContext appCtx ;
4243 private ConnectionInvokerService connInvokerService ;
43-
44+
45+ private static final String APP = "BBB" ;
46+
47+ @ Override
48+ public boolean appConnect (IConnection conn , Object [] params ) {
49+ log .debug ("***** " + APP + " [ " + " appConnect *********" );
50+ return super .appConnect (conn , params );
51+ }
52+
53+ @ Override
54+ public void appDisconnect (IConnection conn ) {
55+ log .debug ("***** " + APP + " [ " + " appDisconnect *********" );
56+ super .appDisconnect (conn );
57+ }
58+
59+ @ Override
60+ public boolean appJoin (IClient client , IScope scope ) {
61+ log .debug ("***** " + APP + " [ " + " appJoin [ " + scope .getName () + "] *********" );
62+ return super .appJoin (client , scope );
63+ }
64+
65+ @ Override
66+ public void appLeave (IClient client , IScope scope ) {
67+ log .debug ("***** " + APP + " [ " + " appLeave [ " + scope .getName () + "] *********" );
68+ super .appLeave (client , scope );
69+ }
70+
71+ @ Override
72+ public boolean roomJoin (IClient client , IScope scope ) {
73+ log .debug ("***** " + APP + " [ " + " roomJoin [ " + scope .getName () + "] *********" );
74+ return super .roomJoin (client , scope );
75+ }
76+
77+ @ Override
78+ public void roomLeave (IClient client , IScope scope ) {
79+ log .debug ("***** " + APP + " [ " + " roomLeave [ " + scope .getName () + "] *********" );
80+ super .roomLeave (client , scope );
81+ }
82+
4483 @ Override
4584 public boolean appStart (IScope app ) {
46- log . debug ( "Starting BigBlueButton " );
85+ log . debug ( "***** " + APP + " [ " + " appStart [ " + scope . getName () + "] *********" );
4786 IContext context = app .getContext ();
4887 appCtx = (AbstractApplicationContext ) context .getApplicationContext ();
4988 appCtx .addApplicationListener (new ShutdownHookListener ());
5089 appCtx .registerShutdownHook ();
51- return super .appStart (app );
90+ super .appStart (app );
91+
92+ connInvokerService .start ();
93+
94+ return true ;
5295 }
5396
5497 @ Override
5598 public void appStop (IScope app ) {
56- log .debug ("Stopping BigBlueButton " );
99+ log .debug ("***** " + APP + " [ " + " appStop [ " + scope .getName () + "] *********" );
100+ connInvokerService .stop ();
57101 super .appStop (app );
58102 }
59103
60104 @ Override
61105 public boolean roomStart (IScope room ) {
62- log .debug ("Starting room [ " + room .getName () + "]. " );
63- assert participantsApplication != null ;
64- connInvokerService .addScope (room .getName (), room );
106+ log .debug ("***** " + APP + " [ "" roomStart [ " + scope .getName () + "] ********* " );
107+
108+ connInvokerService .addScope (room .getName (), room );
65109 return super .roomStart (room );
66110 }
67111
68112 @ Override
69113 public void roomStop (IScope room ) {
70- log .debug ("Stopping room [" + room .getName () + "]." );
71- super .roomStop (room );
72- assert participantsApplication != null ;
114+ log .debug ("***** " + APP + " [ " + " roomStop [ " + scope .getName () + "] *********" );
115+
73116 participantsApplication .destroyRoom (room .getName ());
74117 BigBlueButtonSession bbbSession = getBbbSession ();
75- assert bbbSession != null ;
76118
77- /**
78- * Need to figure out if the next 2 lines should be removed. (ralam nov 25, 2010).
79- */
80- assert recorderApplication != null ;
81119 recorderApplication .destroyRecordSession (bbbSession .getSessionName ());
82120 connInvokerService .removeScope (room .getName ());
83- log .debug ("Stopped room [" + room .getName () + "]." );
121+
122+ super .roomStop (room );
84123 }
85124
86125 @ Override
87126 public boolean roomConnect (IConnection connection , Object [] params ) {
88- String remoteHost = Red5 . getConnectionLocal ().getRemoteAddress ( );
89- int remotePort = Red5 . getConnectionLocal (). getRemotePort ();
127+ log . debug ( "***** " + APP + " [ " + " roomConnect [ " + connection . getScope ().getName () + "] *********" );
128+
90129 String username = ((String ) params [0 ]).toString ();
91130 String role = ((String ) params [1 ]).toString ();
92131 String conference = ((String )params [2 ]).toString ();
93132
94- /*
95- * Convert the id to Long because it gets converted to ascii decimal
96- * equivalent (i.e. zero (0) becomes 48) if we don't.
97- */
98- long clientID = Long .parseLong (Red5 .getConnectionLocal ().getClient ().getId ());
99133 String sessionName = ((String )params [3 ]).toString ();
100- log .info ("[clientid=" + clientID + "] connected from " + remoteHost + ":" + remotePort + "." );
101-
134+
102135 String voiceBridge = ((String ) params [4 ]).toString ();
103136 String room = sessionName ;
104- assert recorderApplication != null ;
137+
105138 boolean record = (Boolean )params [5 ];
106- log .debug ("record value - [" + record + "]" );
107-
139+
108140 String externalUserID = ((String ) params [6 ]).toString ();
109141 String internalUserID = ((String ) params [7 ]).toString ();
110142
111143 if (record == true ) {
112144 recorderApplication .createRecordSession (sessionName );
113145 }
114146
115- BigBlueButtonSession bbbSession = new BigBlueButtonSession (sessionName , clientID , internalUserID , username , role ,
147+ BigBlueButtonSession bbbSession = new BigBlueButtonSession (sessionName , internalUserID , username , role ,
116148 conference , room , voiceBridge , record , externalUserID );
117149 connection .setAttribute (Constants .SESSION , bbbSession );
118150
119151 String debugInfo = "internalUserID=" + internalUserID + ",username=" + username + ",role=" + role + ",conference=" + conference + "," +
120152 "session=" + sessionName + ",voiceConf=" + voiceBridge + ",room=" + room + ",externalUserid=" + externalUserID ;
121153 log .debug ("User [{}] connected to room [{}]" , debugInfo , room );
122154 participantsApplication .createRoom (room );
123- super .roomConnect (connection , params );
124-
155+
125156 connInvokerService .addConnection (bbbSession .getInternalUserID (), connection );
126- return true ;
157+
158+ return super .roomConnect (connection , params );
159+
127160 }
128161
129162 @ Override
130163 public void roomDisconnect (IConnection conn ) {
164+ log .debug ("***** " + APP + " [ " + " roomDisconnect [ " + conn .getScope ().getName () + "] *********" );
165+
131166 String remoteHost = Red5 .getConnectionLocal ().getRemoteAddress ();
132167 int remotePort = Red5 .getConnectionLocal ().getRemotePort ();
133168 String clientId = Red5 .getConnectionLocal ().getClient ().getId ();
134- log .info ("[clientid=" + clientId + "] disconnnected from " + remoteHost + ":" + remotePort + "." );
169+ log .info ("***** " + APP + " [clientid="clientId + "] disconnnected from " + remoteHost + ":" + remotePort + "." );
135170
136171 connInvokerService .removeConnection (getBbbSession ().getInternalUserID ());
137172
@@ -167,7 +202,6 @@ private BigBlueButtonSession getBbbSession() {
167202 }
168203
169204 public void setConnInvokerService (ConnectionInvokerService connInvokerService ) {
170- System .out .print ("Setting conn invoket service!!!!" );
171205 this .connInvokerService = connInvokerService ;
172206 }
173207
0 commit comments