initial commit

com/raphfrk/bukkit/synctest/SyncTest.java

@@ -0,0 +1,49 @@
+package com.raphfrk.bukkit.synctest;
+
+import java.io.File;
+import java.util.concurrent.TimeUnit;
+import java.util.logging.Logger;
+
+import org.bukkit.Server;
+import org.bukkit.event.Event;
+import org.bukkit.event.Event.Priority;
+import org.bukkit.plugin.PluginDescriptionFile;
+import org.bukkit.plugin.PluginLoader;
+import org.bukkit.plugin.PluginManager;
+import org.bukkit.plugin.java.JavaPlugin;
+
+public class SyncTest extends JavaPlugin {
+
+	static final String slash = System.getProperty("file.separator");
+
+	final Server server = getServer();
+
+	PluginManager pm = server.getPluginManager();
+
+	static Logger log;
+
+	public SyncTest(PluginLoader pluginLoader, Server instance, PluginDescriptionFile desc, File folder, File plugin, ClassLoader cLoader) {
+		super(pluginLoader, instance, desc, folder, plugin, cLoader);
+
+	}
+
+	private SyncTestPlayerListener playerListener = new SyncTestPlayerListener( this );
+
+	public void onEnable() {
+
+
+		String name = "Sync Test";
+
+		log = Logger.getLogger("Minecraft");
+		log.info(name + "initialized");
+
+		pm.registerEvent(Event.Type.PLAYER_COMMAND, playerListener, Priority.Normal, this);
+		pm.registerEvent(Event.Type.PLAYER_CHAT, playerListener, Priority.Normal, this);
+	}
+
+	public void onDisable() {
+
+	}
+
+
+}

com/raphfrk/bukkit/synctest/SyncTestPlayerListener.java

@@ -0,0 +1,46 @@
+package com.raphfrk.bukkit.synctest;
+
+import org.bukkit.entity.Player;
+import org.bukkit.event.Event.Type;
+import org.bukkit.event.player.PlayerChatEvent;
+import org.bukkit.event.player.PlayerListener;
+
+class SyncTestPlayerListener extends PlayerListener {
+
+	SyncTest p;
+
+	public SyncTestPlayerListener ( SyncTest plugin ) {
+		p = plugin;
+	};
+
+    public void onPlayerCommand(PlayerChatEvent event) {
+
+    	String message = event.getMessage();
+
+    	Player player = event.getPlayer();
+
+    	String[] split = message.split(" ");
+
+    	event.getPlayer().sendMessage("split 0: " + split[0] );
+
+    	if( split[0].equals("/say")) {
+
+    		PlayerChatEvent playerChatEvent = new PlayerChatEvent(Type.PLAYER_CHAT,player,message);
+
+    		Long delay = Long.parseLong(split[1]);
+
+    		event.getPlayer().sendMessage("Adding to async queue: " + delay);
+    		p.getServer().getAsyncEventManager().callAsyncEvent(playerChatEvent, delay);
+
+    	}
+
+    	event.setCancelled(true);
+
+    }
+
+    public void onPlayerChat(PlayerChatEvent event) {
+
+    	event.getPlayer().sendMessage("Message received: " + event.getMessage());
+
+    }
+}

plugin.yml

@@ -0,0 +1,3 @@
+name: Sync Test
+main: com.raphfrk.bukkit.synctest.SyncTest
+version: 1