~Pushing just because I don't want to lose anything by mistake.

HOWEVER! THIS IS NOT A NEW VERSION OF NETWORKING! NEW VERSION COMING SOON BASED ON ME AN JYTHONS TALK!

Author: Exerosis

src/main/java/org/blockserver/core/event/MessageEventListener.java

@@ -18,7 +18,7 @@
 
 import org.blockserver.core.Server;
 import org.blockserver.core.events.MessageHandleEvent;
-import org.blockserver.core.message.Message;
+import org.blockserver.core.modules.message.Message;
 
 /**
  * Written by Exerosis!

src/main/java/org/blockserver/core/event/ServerEventListener.java

@@ -0,0 +1,38 @@
+/*
+ * This file is part of BlockServer.
+ *
+ * BlockServer is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * BlockServer is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.blockserver.core.event;
+
+import org.blockserver.core.Server;
+
+/**
+ * Written by Exerosis!
+ */
+public class ServerEventListener<B> extends EventListener<B, B> {
+    public void register(Class<B> listenerType, Server server) {
+        register(listenerType, server.getEventManager());
+    }
+
+    public ServerEventListener<B> post() {
+        super.post();
+        return this;
+    }
+
+    public ServerEventListener<B> priority(Priority priority) {
+        super.priority(priority);
+        return this;
+    }
+}

src/main/java/org/blockserver/core/events/MessageHandleEvent.java

@@ -19,7 +19,7 @@
 import lombok.Getter;
 import lombok.Setter;
 import org.blockserver.core.event.CancellableImplementation;
-import org.blockserver.core.message.Message;
+import org.blockserver.core.modules.message.Message;
 
 /**
  * Written by Exerosis!

src/main/java/org/blockserver/core/events/packets/PacketEvent.java

@@ -0,0 +1,33 @@
+/*
+ * This file is part of BlockServer.
+ *
+ * BlockServer is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * BlockServer is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.blockserver.core.events.packets;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.blockserver.core.event.CancellableImplementation;
+import org.blockserver.core.modules.network.RawPacket;
+
+/**
+ * Written by Exerosis!
+ */
+public class PacketEvent implements CancellableImplementation {
+    @Getter @Setter private RawPacket packet;
+
+    public PacketEvent(RawPacket packet) {
+        this.packet = packet;
+    }
+}

src/main/java/org/blockserver/core/events/packets/PacketReceiveEvent.java

@@ -0,0 +1,28 @@
+/*
+ * This file is part of BlockServer.
+ *
+ * BlockServer is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * BlockServer is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.blockserver.core.events.packets;
+
+import org.blockserver.core.modules.network.RawPacket;
+
+/**
+ * Written by Exerosis!
+ */
+public class PacketReceiveEvent extends PacketEvent {
+    public PacketReceiveEvent(RawPacket packet) {
+        super(packet);
+    }
+}

src/main/java/org/blockserver/core/events/packets/PacketSendEvent.java

@@ -0,0 +1,28 @@
+/*
+ * This file is part of BlockServer.
+ *
+ * BlockServer is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * BlockServer is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.blockserver.core.events.packets;
+
+import org.blockserver.core.modules.network.RawPacket;
+
+/**
+ * Written by Exerosis!
+ */
+public class PacketSendEvent extends PacketEvent {
+    public PacketSendEvent(RawPacket packet) {
+        super(packet);
+    }
+}

src/main/java/org/blockserver/core/modules/entity/Entity.java

@@ -0,0 +1,42 @@
+/*
+ * This file is part of BlockServer.
+ *
+ * BlockServer is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * BlockServer is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.blockserver.core.modules.entity;
+
+import org.blockserver.core.modules.world.positions.Location;
+
+/**
+ * Written by Exerosis!
+ */
+public class Entity {
+    private float x;
+    private float y;
+    private float z;
+
+    public Entity(float x, float y, float z) {
+        this.x = x;
+        this.y = y;
+        this.z = z;
+    }
+
+    public Entity(Location location) {
+        this(location.getX(), location.getY(), location.getZ());
+    }
+
+    public Location getLocation() {
+        return new Location(x, y, z);
+    }
+}

src/main/java/org/blockserver/core/message/Message.java renamed to src/main/java/org/blockserver/core/modules/message/Message.java

@@ -14,7 +14,7 @@
  * You should have received a copy of the GNU Lesser General Public License
  * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
  */
-package org.blockserver.core.message;
+package org.blockserver.core.modules.message;
 
 import lombok.Getter;
 import lombok.Setter;

src/main/java/org/blockserver/core/message/MessageInPlayerLogin.java renamed to src/main/java/org/blockserver/core/modules/message/MessageInPlayerLogin.java

@@ -14,7 +14,7 @@
  * You should have received a copy of the GNU Lesser General Public License
  * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
  */
-package org.blockserver.core.message;
+package org.blockserver.core.modules.message;
 
 import org.blockserver.core.modules.player.Player;
 

src/main/java/org/blockserver/core/message/MessageModule.java renamed to src/main/java/org/blockserver/core/modules/message/MessageModule.java

@@ -14,14 +14,13 @@
  * You should have received a copy of the GNU Lesser General Public License
  * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
  */
-package org.blockserver.core.message;
+package org.blockserver.core.modules.message;
 
 import org.blockserver.core.Server;
 import org.blockserver.core.events.MessageHandleEvent;
 import org.blockserver.core.events.RawPacketHandleEvent;
 import org.blockserver.core.modules.network.NetworkConverter;
 import org.blockserver.core.modules.network.NetworkModule;
-import org.blockserver.core.modules.network.NetworkProvider;
 import org.blockserver.core.modules.scheduler.SchedulerModule;
 
 /**
@@ -30,6 +29,7 @@
 public class MessageModule extends NetworkModule {
     private final NetworkConverter networkConverter;
 
+    //TODO figure out a way to make the converter part async.
     public MessageModule(Server server, SchedulerModule schedulerModule, NetworkConverter networkConverter) {
         super(server, schedulerModule);
         this.networkConverter = networkConverter;
@@ -47,8 +47,10 @@ public MessageModule(Server server, SchedulerModule schedulerModule, NetworkConv
 
 
     public void sendMessage(Message message) {
-        for (NetworkProvider provider : getProviders()) {
-            provider.queueOutboundPackets(networkConverter.toPacket(message));
-        }
+        getServer().getExecutorService().execute(() -> {
+            for (NetworkProvider provider : getProviders()) {
+                provider.queueOutboundPackets(networkConverter.toPacket(message));
+            }
+        });
     }
 }

src/main/java/org/blockserver/core/modules/message/PlayerLoginMessage.java

@@ -0,0 +1,36 @@
+/*
+ * This file is part of BlockServer.
+ *
+ * BlockServer is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * BlockServer is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.blockserver.core.modules.message;
+
+import org.blockserver.core.modules.player.Player;
+import org.blockserver.core.utilities.Skin;
+
+import java.util.UUID;
+
+/**
+ * Written by Exerosis!
+ */
+public class PlayerLoginMessage extends Message {
+    public long clientID;
+    public String username;
+    public UUID uuid;
+    public Skin skin;
+
+    public PlayerLoginMessage(Player player) {
+        super(player);
+    }
+}

src/main/java/org/blockserver/core/message/block/MessageOutBlockChange.java renamed to src/main/java/org/blockserver/core/modules/message/block/MessageOutBlockChange.java

@@ -14,9 +14,9 @@
  * You should have received a copy of the GNU Lesser General Public License
  * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
  */
-package org.blockserver.core.message.block;
+package org.blockserver.core.modules.message.block;
 
-import org.blockserver.core.message.Message;
+import org.blockserver.core.modules.message.Message;
 import org.blockserver.core.modules.player.Player;
 import org.blockserver.core.modules.world.Block;
 

src/main/java/org/blockserver/core/modules/network/LinkedBlockingIOQueue.java

@@ -0,0 +1,54 @@
+/*
+ * This file is part of BlockServer.
+ *
+ * BlockServer is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * BlockServer is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with BlockServer.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package org.blockserver.core.modules.network;
+
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
+
+/**
+ * Written by Exerosis!
+ */
+public class LinkedBlockingIOQueue<T> {
+    private final BlockingQueue<T> input = new LinkedBlockingQueue<>();
+    private final BlockingQueue<T> output = new LinkedBlockingQueue<>();
+
+    public void queueInbound(T object) {
+        input.add(object);
+    }
+
+    public void queueOutbound(T object) {
+        output.add(object);
+    }
+
+
+    public T pollInbound() {
+        return input.poll();
+    }
+
+    public T pollOutbound() {
+        return output.poll();
+    }
+
+
+    public T peekInbound() {
+        return input.peek();
+    }
+
+    public T peekOutbound() {
+        return output.peek();
+    }
+}

src/main/java/org/blockserver/core/modules/network/NetworkConverter.java

@@ -17,7 +17,7 @@
 package org.blockserver.core.modules.network;
 
 
-import org.blockserver.core.message.Message;
+import org.blockserver.core.modules.message.Message;
 
 /**
  * Written by Exerosis!