Comet Client for Android

package hk.com.novare.cometclient;import org.cometd.Client;import org.cometd.Message;import org.cometd.MessageListener;import org.mortbay.cometd.AbstractBayeux;import org.mortbay.cometd.client.BayeuxClient;import org.mortbay.jetty.client.Address;import org.mortbay.jetty.client.ContentExchange;import org.mortbay.jetty.client.HttpClient;import org.mortbay.util.ajax.JSON;import android.app.Activity;import android.os.Bundle;import android.os.Handler;import android.util.Log;import android.view.View;import android.widget.Button;import android.widget.Toast;public class CometClientActivity extends Activity {	private volatile boolean running;		private Button fireButton = null;		private Handler labelHandler = new Handler() {		@Override		public void handleMessage(android.os.Message msg) {			if (fireButton != null) {				fireButton.setText((String) msg.obj);			}		}			};	    /** Called when the activity is first created. */    @Override    public void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.main);                fireButton = (Button) findViewById(R.id.fireButton);                fireButton.setOnClickListener(new View.OnClickListener() {			public void onClick(View v) {				new Thread(new Runnable() {					public void run() {						if (running == false) {							android.os.Message m = labelHandler.obtainMessage(0, "Stop");							labelHandler.sendMessage(m);							running = true;							goDojo();						} else {							android.os.Message m = labelHandler.obtainMessage(0, "Start");							labelHandler.sendMessage(m);							running = false;						}					}				}).start();			}        	        });    }        void goDojo() {		final HttpClient httpClient = new HttpClient();		try {			httpClient.setConnectorType(HttpClient.CONNECTOR_SOCKET);			// Fails immediately//			httpClient.setConnectorType(HttpClient.CONNECTOR_SELECT_CHANNEL);			httpClient.start();			final BayeuxClient bayeuxClient = new BayeuxClient(httpClient,					new Address("10.9.7.90", 8080), "/cometd/cometd");			final MessageListener messageListener = new MessageListener() {				public void deliver(Client arg0, Client arg1, Message arg2) {					Log.d("CometClientActivity", arg2.toString());				}			};			bayeuxClient.addListener(messageListener);			bayeuxClient.start();						final String channel = "/chat/demo";						bayeuxClient.subscribe(channel);								final String name = "clientName";			final String chat = "smallMessage";			Object msg=new JSON.Literal("{\"user\":\"" + name + "\",\"chat\":\"" + chat + "\"}");						int n = 0;			while (running) {				bayeuxClient.publish(channel, msg, String.valueOf(n++));				try {					Thread.sleep(10000L);				} catch (InterruptedException e) {					// Nothing				}							}								} catch (Exception e) {			Log.d("CometClientActivity", "Comet Fail", e);		}    }     }