From 407ea69176af9045f3f07bbcafd8d1c718846711 Mon Sep 17 00:00:00 2001 From: Kevin Smith Date: Mon, 23 Apr 2012 18:04:39 +0100 Subject: Basic example diff --git a/src/com/isode/stroke/examples/ConnectDisconnect.java b/src/com/isode/stroke/examples/ConnectDisconnect.java new file mode 100644 index 0000000..5181fcc --- /dev/null +++ b/src/com/isode/stroke/examples/ConnectDisconnect.java @@ -0,0 +1,102 @@ +/* + * Copyright (c) 2010, Isode Limited, London, England. + * All rights reserved. + */ +package com.isode.stroke.examples; + +import com.isode.stroke.client.ClientError; +import com.isode.stroke.client.ClientOptions; +import com.isode.stroke.client.CoreClient; +import com.isode.stroke.elements.Message; +import com.isode.stroke.eventloop.DummyEventLoop; +import com.isode.stroke.jid.JID; +import com.isode.stroke.network.JavaNetworkFactories; +import com.isode.stroke.signals.Slot; +import com.isode.stroke.signals.Slot1; + +/** + * Simple example. + * Connects, + * disconnects, + * connects, + * sends a message, + * receives the message, + * logs out. + * @author kismith + */ +public class ConnectDisconnect { + + private boolean running = true; + private JID jid; + int connectCount = 0; + CoreClient client; + ClientOptions options = new ClientOptions(); + + private void handleConnected() { + connectCount++; + if (connectCount == 1) { + System.out.println("First connection"); + client.disconnect(); + } else { + System.out.println("Second connection"); + Message message = new Message(); + message.setTo(client.getJID()); + message.setBody("Ooh, a message"); + message.setID("BLAH"); + client.sendMessage(message); + } + } + + private void handleDisconnected(ClientError error) { + if (connectCount == 1) { + System.out.println("First disconnection"); + client.connect(options); + } else { + System.out.println("Last connection"); + running = false; + } + } + + private void handleMessageReceived(Message message) { + if (connectCount == 2 && message.getID().equals("BLAH")) { + System.out.println("Message received"); + client.disconnect(); + } + } + + public void go(String args[]) { + jid = new JID(args[0]); + String password = args[1]; + DummyEventLoop eventLoop = new DummyEventLoop(); + JavaNetworkFactories factories = new JavaNetworkFactories(eventLoop); + + client = new CoreClient(eventLoop, jid, password, factories); + client.onConnected.connect(new Slot() { + + public void call() { + handleConnected(); + } + }); + client.onDisconnected.connect(new Slot1() { + + public void call(ClientError p1) { + handleDisconnected(p1); + } + }); + client.onMessageReceived.connect(new Slot1() { + + public void call(Message p1) { + handleMessageReceived(p1); + } + }); + client.connect(options); + while (running) { + eventLoop.processEvents(); + } + + } + + public static void main(String args[]) { + new ConnectDisconnect().go(args); + } +} -- cgit v0.10.2-6-g49f6