spenk

ClientWorker

Feb 15th, 2012
118
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.52 KB | None | 0 0
  1. import java.io.BufferedReader;
  2. import java.io.IOException;
  3. import java.io.InputStreamReader;
  4. import java.net.Socket;
  5. import java.util.logging.Logger;
  6.  
  7. class ClientWorker
  8.   implements Runnable
  9. {
  10.   private Socket client;
  11.   protected static final Logger log = Logger.getLogger("Minecraft");
  12.  
  13.   ClientWorker(Socket client) {
  14.     this.client = client;
  15.   }
  16.   public void exec_meow(String line) {
  17.     PropertiesFile options = new PropertiesFile("mcban.properties");
  18.     for (Player pi : etc.getServer().getPlayerList())
  19.       if (pi.isAdmin()) {
  20.         log.info(line);
  21.         Boolean enable_mcbansay = Boolean.valueOf(options.getBoolean("chat_enable"));
  22.         if (enable_mcbansay.booleanValue())
  23.           pi.sendMessage("§4[MCBans Chat] §f" + line);
  24.       }
  25.   }
  26.  
  27.   public void run()
  28.   {
  29.     BufferedReader in = null;
  30.     try {
  31.       in = new BufferedReader(new InputStreamReader(
  32.         this.client.getInputStream()));
  33.     } catch (Exception e) {
  34.       log.severe("[MCBANS] MCBans Chat Error, could not read message (pre).");
  35.     }
  36.     while (true)
  37.       try
  38.       {
  39.         String line = in.readLine();
  40.  
  41.         if ((line == null) || (line.isEmpty())) break;
  42.         exec_meow(line); continue;
  43.       }
  44.       catch (Exception e)
  45.       {
  46.         log.severe("[MCBANS] MCBans Chat Error, could not read message (post).");
  47.         try {
  48.           this.client.close();
  49.         } catch (IOException i) {
  50.           log.severe("[MCBANS] MCBans Chat Error, could not close client socket.");
  51.         }
  52.       }
  53.   }
  54. }
Advertisement
Add Comment
Please, Sign In to add comment