@@ -91,20 +91,20 @@ public String save(Object meetingCode, String sessionId, String message) {
9191 * @return builder
9292 */
9393 public final String save (final Object meetingCode , final Builder builder ) {
94- BlockingQueue <Builder > messages ;
95- if ((messages = this .meetings .get (meetingCode )) == null ) {
96- this .meetings .put (meetingCode .toString (), messages = new ArrayBlockingQueue <Builder >(DEFAULT_MESSAGE_POOL_SIZE ));
94+ if ((this .meetings .get (meetingCode )) == null ) {
95+ this .meetings .put (meetingCode .toString (), new ArrayBlockingQueue <Builder >(DEFAULT_MESSAGE_POOL_SIZE ));
9796 }
9897
9998 try {
100- messages .put (builder );
99+ this . meetings . get ( meetingCode ) .put (builder );
101100
101+ final BlockingQueue <Builder > messages = this .meetings .get (meetingCode );
102102 this .getService ().execute (new Runnable (){
103103 @ Override
104104 public void run () {
105105 Builder message ;
106- if (talk . this . meetings . get ( meetingCode ) == null || ( message = talk . this . meetings . get ( meetingCode ) .poll ()) == null ) return ;
107- talk . this . copy (meetingCode , message );
106+ if (( message = messages .poll ()) == null ) return ;
107+ copy (meetingCode , message );
108108 }
109109 });
110110 return builder .toString ();
@@ -159,11 +159,12 @@ protected String filter(String text) {
159159 * @param builder
160160 */
161161 private final void copy (Object meetingCode , Builder builder ) {
162- final Collection <Entry <String , Queue <Builder >>> set = this .list .entrySet ();
163- final Iterator <Entry <String , Queue <Builder >>> iterator = set .iterator ();
164162 final List <String > _sessions ;
165163
166164 if ((_sessions = this .sessions .get (meetingCode )) != null ) {
165+ final Collection <Entry <String , Queue <Builder >>> set = this .list .entrySet ();
166+ final Iterator <Entry <String , Queue <Builder >>> iterator = set .iterator ();
167+
167168 while (iterator .hasNext ()) {
168169 Entry <String , Queue <Builder >> list = iterator .next ();
169170 if (_sessions .contains (list .getKey ())) {
0 commit comments