From 86619275992b4b29bfac91897986b10f2ef863cb Mon Sep 17 00:00:00 2001
From: KHobbits <rob@khobbits.co.uk>
Date: Mon, 31 Dec 2012 02:28:52 +0000
Subject: Merge gravy's pull and reformat code

---
 EssentialsXMPP/src/net/ess3/xmpp/XMPPManager.java | 102 +++++++++++-----------
 1 file changed, 52 insertions(+), 50 deletions(-)

(limited to 'EssentialsXMPP/src/net/ess3/xmpp/XMPPManager.java')

diff --git a/EssentialsXMPP/src/net/ess3/xmpp/XMPPManager.java b/EssentialsXMPP/src/net/ess3/xmpp/XMPPManager.java
index bf88aad8b..ac6dddff6 100644
--- a/EssentialsXMPP/src/net/ess3/xmpp/XMPPManager.java
+++ b/EssentialsXMPP/src/net/ess3/xmpp/XMPPManager.java
@@ -6,11 +6,11 @@ import java.util.logging.Handler;
 import java.util.logging.Level;
 import java.util.logging.LogRecord;
 import java.util.logging.Logger;
+import org.bukkit.configuration.file.YamlConfiguration;
+import org.bukkit.entity.Player;
 import net.ess3.api.IReload;
 import net.ess3.api.IUser;
 import net.ess3.utils.FormatUtil;
-import org.bukkit.configuration.file.YamlConfiguration;
-import org.bukkit.entity.Player;
 import org.jivesoftware.smack.*;
 import org.jivesoftware.smack.Roster.SubscriptionMode;
 import org.jivesoftware.smack.packet.Message;
@@ -234,68 +234,70 @@ public final class XMPPManager extends Handler implements MessageListener, ChatM
 
 	private void startLoggerThread()
 	{
-		loggerThread = new Thread(new Runnable()
-		{
-			@Override
-			public void run()
-			{
-				final Set<LogRecord> copy = new HashSet<LogRecord>();
-				final Set<String> failedUsers = new HashSet<String>();
-				while (threadrunning)
+		loggerThread = new Thread(
+				new Runnable()
 				{
-					synchronized (logrecords)
-					{
-						if (!logrecords.isEmpty())
-						{
-							copy.addAll(logrecords);
-							logrecords.clear();
-						}
-					}
-					if (!copy.isEmpty())
+					@Override
+					public void run()
 					{
-						for (String user : logUsers)
+						final Set<LogRecord> copy = new HashSet<LogRecord>();
+						final Set<String> failedUsers = new HashSet<String>();
+						while (threadrunning)
 						{
-							try
+							synchronized (logrecords)
+							{
+								if (!logrecords.isEmpty())
+								{
+									copy.addAll(logrecords);
+									logrecords.clear();
+								}
+							}
+							if (!copy.isEmpty())
 							{
-								XMPPManager.this.startChat(user);
-								for (LogRecord logRecord : copy)
+								for (String user : logUsers)
 								{
-									final String message = String.format("[" + logRecord.getLevel().getLocalizedName() + "] " + logRecord.getMessage(), logRecord.getParameters());
-									if (!XMPPManager.this.sendMessage(user, message))
+									try
+									{
+										XMPPManager.this.startChat(user);
+										for (LogRecord logRecord : copy)
+										{
+											final String message = String.format(
+													"[" + logRecord.getLevel().getLocalizedName() + "] " + logRecord.getMessage(), logRecord.getParameters());
+											if (!XMPPManager.this.sendMessage(user, message))
+											{
+												failedUsers.add(user);
+												break;
+											}
+
+										}
+									}
+									catch (XMPPException ex)
 									{
 										failedUsers.add(user);
-										break;
+										LOGGER.removeHandler(XMPPManager.this);
+										LOGGER.log(Level.SEVERE, "Failed to deliver log message! Disabling logging to XMPP.", ex);
 									}
-
 								}
+								logUsers.removeAll(failedUsers);
+								if (logUsers.isEmpty())
+								{
+									LOGGER.removeHandler(XMPPManager.this);
+									threadrunning = false;
+								}
+								copy.clear();
 							}
-							catch (XMPPException ex)
+							try
 							{
-								failedUsers.add(user);
-								LOGGER.removeHandler(XMPPManager.this);
-								LOGGER.log(Level.SEVERE, "Failed to deliver log message! Disabling logging to XMPP.", ex);
+								Thread.sleep(2000);
+							}
+							catch (InterruptedException ex)
+							{
+								threadrunning = false;
 							}
 						}
-						logUsers.removeAll(failedUsers);
-						if (logUsers.isEmpty())
-						{
-							LOGGER.removeHandler(XMPPManager.this);
-							threadrunning = false;
-						}
-						copy.clear();
-					}
-					try
-					{
-						Thread.sleep(2000);
+						LOGGER.removeHandler(XMPPManager.this);
 					}
-					catch (InterruptedException ex)
-					{
-						threadrunning = false;
-					}
-				}
-				LOGGER.removeHandler(XMPPManager.this);
-			}
-		});
+				});
 		loggerThread.start();
 	}
 
-- 
cgit v1.2.3