# API

SocketOpts opts = new SocketOpts("http://mock.dfocus.com", "your projectId", "your token");
SocketIOFactory factory = new SocketIOFactory(opts);
SocketIoClientBiz biz = new SocketIoClientBiz(factory);

biz.connect(new Finish() {
    @Override
    public void onFinished(String errorMessage) {
		if ("".equals(errorMessage)) {
			System.out.println("connected");
		} else {
			System.out.println("failed to connect");
		}
    }
});

// watch every connection state change
Subscription stateChangeSub = biz.onStateChange(new StateChangeCallback() {
    @Override
    public void onChange(ClientState s) {
		System.out.println("state changed to " + s);
    }
});

// you can dispose this subscription later
stateChangeSub.dispose();

// watch for specific event along with its topic
Subscription eventSub = biz.subscribe("spaces", "SPACE_ADDED", new EventCallback() {
    @Override
    public void onFire(EventMessage message) {
        System.out.println("event = " + message.getPayload());
    }
});

// you can dispose this subscription later
eventSub.dispose();

biz.disconnect();