package de.d3adspace.heimdall.client;

import de.d3adspace.heimdall.server.HeimdallServer;
import de.d3adspace.heimdall.server.HeimdallServerFactory;
import de.d3adspace.heimdall.server.config.HeimdallServerConfig;
import de.d3adspace.heimdall.server.config.HeimdallServerConfigBuilder;

public class HeimdallServerExample {

	public static void main(String[] args) {
		HeimdallServerConfig config = new HeimdallServerConfigBuilder()
			.setServerHost("localhost")
			.setServerPort(1337)
			.createHeimdallServerConfig();

		HeimdallServer heimdallServer = HeimdallServerFactory.createHeimdallServer(config);
		heimdallServer.start();
	}
}

package de.d3adspace.heimdall.client;

import de.d3adspace.heimdall.client.HeimdallClient;
import de.d3adspace.heimdall.client.HeimdallClientFactory;
import de.d3adspace.heimdall.client.annotation.Channel;
import de.d3adspace.heimdall.client.config.HeimdallClientConfig;
import de.d3adspace.heimdall.client.config.HeimdallClientConfigBuilder;
import de.d3adspace.heimdall.client.handler.PacketHandler;
import org.json.JSONObject;

public class HeimdallClientExample {

	public static void main(String[] args) {
		HeimdallClientConfig config = new HeimdallClientConfigBuilder()
			.setServerHost("localhost")
			.setServerPort(1337)
			.createHeimdallClientConfig();

		HeimdallClient client = HeimdallClientFactory.createHeimdallClient(config);
    client.connect();

		PacketHandler packetHandler = new PacketHandlerExample();
		client.subscribe(packetHandler);

		client.publish("cluster", new JSONObject().put("Hello", "World!"));

		client.unsubscribe(packetHandler);

		client.disconnect();
	}
}

package de.d3adspace.heimdall.client;

import de.d3adspace.heimdall.client.annotation.Channel;
import de.d3adspace.heimdall.client.handler.PacketHandler;
import org.json.JSONObject;

@Channel("cluster")
public class PacketHandlerExample implements PacketHandler {

	public void handlePacket(JSONObject jsonObject) {
		System.out.println("Message in cluster: " + jsonObject);
	}
}