src/main/java/re/jag/mcqtt/Mcqtt.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

package re.jag.mcqtt;

import net.fabricmc.api.ModInitializer;

import net.minecraft.server.MinecraftServer;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;

public class Mcqtt implements ModInitializer {
	public static final Logger LOG = LogManager.getLogger();
    private static MinecraftServer server = null;

	@Override
	public void onInitialize() {
		System.out.println("Hello Fabric world!");

		try {
			MqttClient mqtt = new MqttClient("tcp://localhost", "mcserver", null);
		} catch (MqttException e) {}
	}

	public static void onStart(MinecraftServer _server) {
		if (server == null)
			server = _server;
	}

	public static void onTick() {
		//LOG.info("TICK: " + String.valueOf(server.getTickTime()) + "ms");
	}
}