diff options
author | Kevin Smith <git@kismith.co.uk> | 2012-04-23 17:04:39 (GMT) |
---|---|---|
committer | Kevin Smith <git@kismith.co.uk> | 2012-04-23 17:04:58 (GMT) |
commit | 407ea69176af9045f3f07bbcafd8d1c718846711 (patch) | |
tree | 9c5ad3dacd44cf17ddd08878da2593cdee633d7f /src/com/isode | |
parent | 19ea69686d0af6977fe02bc29a664d57195b8127 (diff) | |
download | stroke-407ea69176af9045f3f07bbcafd8d1c718846711.zip stroke-407ea69176af9045f3f07bbcafd8d1c718846711.tar.bz2 |
Basic example
Diffstat (limited to 'src/com/isode')
-rw-r--r-- | src/com/isode/stroke/examples/ConnectDisconnect.java | 102 |
1 files changed, 102 insertions, 0 deletions
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<ClientError>() { + + public void call(ClientError p1) { + handleDisconnected(p1); + } + }); + client.onMessageReceived.connect(new Slot1<Message>() { + + public void call(Message p1) { + handleMessageReceived(p1); + } + }); + client.connect(options); + while (running) { + eventLoop.processEvents(); + } + + } + + public static void main(String args[]) { + new ConnectDisconnect().go(args); + } +} |