mirror of
https://github.com/2006-Scape/apollo.git
synced 2026-07-03 08:39:11 +00:00
Old-style poll, looks nicer, exceptions in lambda look funky.
This commit is contained in:
@@ -16,7 +16,6 @@ import org.apollo.game.message.Message;
|
||||
import org.apollo.game.message.MessageHandlerChainSet;
|
||||
import org.apollo.game.message.impl.LogoutMessage;
|
||||
import org.apollo.game.model.entity.Player;
|
||||
import org.apollo.util.CollectionUtil;
|
||||
|
||||
/**
|
||||
* A game session.
|
||||
@@ -84,13 +83,14 @@ public final class GameSession extends Session {
|
||||
* @param chainSet The {@link MessageHandlerChainSet}
|
||||
*/
|
||||
public void handlePendingMessages(MessageHandlerChainSet chainSet) {
|
||||
CollectionUtil.pollAll(messageQueue, message -> {
|
||||
Message message;
|
||||
while ((message = messageQueue.poll()) != null) {
|
||||
try {
|
||||
chainSet.notify(player, message);
|
||||
} catch (Exception reason) {
|
||||
logger.log(Level.SEVERE, "Uncaught exception thrown while handling message: " + message, reason);
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user