From 8f38b5ddb890e78eff31cb296d8d59fed2de3df2 Mon Sep 17 00:00:00 2001
From: Tux <write@imaginarycode.com>
Date: Sun, 26 Jun 2016 04:19:10 -0400
Subject: [PATCH] try to fix #40

---
 pom.xml                                          |  8 --------
 .../minecraft/redisbungee/RedisBungee.java       | 16 ++++++++++------
 2 files changed, 10 insertions(+), 14 deletions(-)

diff --git a/pom.xml b/pom.xml
index 3d78e82..bc08c7f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -90,14 +90,6 @@
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-javadoc-plugin</artifactId>
                 <version>2.9.1</version>
-                <executions>
-                    <execution>
-                        <phase>compile</phase>
-                        <goals>
-                            <goal>javadoc</goal>
-                        </goals>
-                    </execution>
-                </executions>
             </plugin>
         </plugins>
     </build>
diff --git a/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java b/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java
index 39270b7..8cb84bd 100644
--- a/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java
+++ b/src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java
@@ -27,12 +27,9 @@ import redis.clients.jedis.*;
 import redis.clients.jedis.exceptions.JedisConnectionException;
 
 import java.io.*;
+import java.lang.reflect.Field;
 import java.util.*;
-import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.FutureTask;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
+import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.logging.Level;
 
@@ -225,7 +222,14 @@ public final class RedisBungee extends Plugin {
 
     @Override
     public void onEnable() {
-        ((ThreadPoolExecutor) getExecutorService()).setMaximumPoolSize(32);
+        ThreadFactory factory = ((ThreadPoolExecutor) getExecutorService()).getThreadFactory();
+        try {
+            Field field = this.getClass().getDeclaredField("executorService");
+            field.setAccessible(true);
+            field.set(this, Executors.newFixedThreadPool(24, factory));
+        } catch (Exception e) {
+
+        }
         try {
             loadConfig();
         } catch (IOException e) {