summaryrefslogtreecommitdiffstats
path: root/EssentialsChat/src
diff options
context:
space:
mode:
authorsnowleo <schneeleo@gmail.com>2012-08-04 11:10:57 +0200
committersnowleo <schneeleo@gmail.com>2012-08-04 11:10:57 +0200
commitbe11f840b40805fd4d9d0214ebfc611182f840fc (patch)
tree37f2f98630f973da4225c99dce7fc3fed57c355b /EssentialsChat/src
parent873cc26b7d8755b48a20043202613aa794914458 (diff)
downloadEssentials-be11f840b40805fd4d9d0214ebfc611182f840fc.tar
Essentials-be11f840b40805fd4d9d0214ebfc611182f840fc.tar.gz
Essentials-be11f840b40805fd4d9d0214ebfc611182f840fc.tar.lz
Essentials-be11f840b40805fd4d9d0214ebfc611182f840fc.tar.xz
Essentials-be11f840b40805fd4d9d0214ebfc611182f840fc.zip
More thread safety
Diffstat (limited to 'EssentialsChat/src')
-rw-r--r--EssentialsChat/src/com/earth2me/essentials/chat/EssentialsChatPlayer.java16
1 files changed, 11 insertions, 5 deletions
diff --git a/EssentialsChat/src/com/earth2me/essentials/chat/EssentialsChatPlayer.java b/EssentialsChat/src/com/earth2me/essentials/chat/EssentialsChatPlayer.java
index 8ca16fbbb..9dce1169c 100644
--- a/EssentialsChat/src/com/earth2me/essentials/chat/EssentialsChatPlayer.java
+++ b/EssentialsChat/src/com/earth2me/essentials/chat/EssentialsChatPlayer.java
@@ -44,11 +44,14 @@ public abstract class EssentialsChatPlayer implements Listener
{
return true;
}
- for (IEssentialsChatListener listener : listeners.values())
+ synchronized (listeners)
{
- if (listener.shouldHandleThisChat(event))
+ for (IEssentialsChatListener listener : listeners.values())
{
- return true;
+ if (listener.shouldHandleThisChat(event))
+ {
+ return true;
+ }
}
}
return false;
@@ -155,9 +158,12 @@ public abstract class EssentialsChatPlayer implements Listener
}
String message = String.format(event.getFormat(), type.concat(sender.getDisplayName()), event.getMessage());
- for (IEssentialsChatListener listener : listeners.values())
+ synchronized (listeners)
{
- message = listener.modifyMessage(event, onlinePlayer, message);
+ for (IEssentialsChatListener listener : listeners.values())
+ {
+ message = listener.modifyMessage(event, onlinePlayer, message);
+ }
}
onlineUser.sendMessage(message);
}