Android

package com.signalr_client;

import java.util.concurrent.ExecutionException;

import microsoft.aspnet.signalr.client.Action;
import microsoft.aspnet.signalr.client.ConnectionState;
import microsoft.aspnet.signalr.client.ErrorCallback;
import microsoft.aspnet.signalr.client.MessageReceivedHandler;
import microsoft.aspnet.signalr.client.Platform;
import microsoft.aspnet.signalr.client.http.android.AndroidPlatformComponent;
import microsoft.aspnet.signalr.client.hubs.HubConnection;
import microsoft.aspnet.signalr.client.hubs.HubProxy;
import android.app.Activity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ListView;
import android.widget.TextView;
import android.widget.Toast;

import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;

public class MainActivity extends Activity {
	HubConnection chatConnection;
	HubProxy SignalRChatHub;

	Button ChatButton;
	EditText ChatInput;
	TextView ChatMessages;

	<a href="http://www.codeproject.com/Members/override">@Override</a>
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		// Platform.loadPlatformComponent(new AndroidPlatformComponent());
		setContentView(R.layout.activity_main);
		// Intent i= new Intent(getApplicationContext(), NotifyService.class);
		// startService(i);

		chatConnection = new HubConnection("http://www.mynotyfy.somee.com/");
		SignalRChatHub = chatConnection.createHubProxy("ChatHub");
		// SignalRChatHub.subscribe(MainActivity.this);

		chatConnection.error(new ErrorCallback() {

			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void onError(final Throwable error) {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								error.getMessage(), Toast.LENGTH_LONG).show();
					}
				});
			}
		});
		Init();

		ChatButton.setOnClickListener(new View.OnClickListener() {

			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void onClick(View v) {
				runThread();
			}
		});
		SignalRChatHub.subscribe(new Object() {
			@SuppressWarnings("unused")
			public void broadcastMessage(final String name, final String message) {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								name + ": " + message, Toast.LENGTH_LONG)
								.show();
					}
				});
			}
		});

		chatConnection.start().done(new Action<Void>() {

			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void run(Void obj) throws Exception {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								"Done Connecting!", Toast.LENGTH_LONG).show();
					}
				});
			}
		});
		chatConnection.received(new MessageReceivedHandler() {
			<a href="http://www.codeproject.com/Members/override">@Override</a>
			public void onMessageReceived(final JsonElement json) {
				runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								"testing!", Toast.LENGTH_LONG).show();
						JsonObject jsonObject = json.getAsJsonObject();
						JsonArray jsonArray = jsonObject.getAsJsonArray("A");
						String messagex = jsonArray.get(0).getAsString() + ": "
								+ jsonArray.get(1).getAsString();
						ChatMessages.append(messagex + "\n");
						Toast.makeText(getApplicationContext(),
								"loading!", Toast.LENGTH_LONG).show();
						// Toast.makeText(getApplicationContext(), messagex ,
						// Toast.LENGTH_LONG).show();
					}
				});
			}
		});
	}

	public void Init() {
		ChatButton = (Button) findViewById(R.id.ChatButton);
		ChatInput = (EditText) findViewById(R.id.ChatInput);
		ChatMessages = (TextView) findViewById(R.id.ChatMessages);
	}

	public void runThread() {

		new Thread(new Runnable() {
			public void run() {
				try {
					Thread.sleep(500);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} 
				MainActivity.this.runOnUiThread(new Runnable() {
					public void run() {
						Toast.makeText(getApplicationContext(),
								"Click button1", Toast.LENGTH_SHORT).show();
						try{
							SignalRChatHub.invoke("Send", "Android", "hixhix");
						}catch(Exception e){
							ChatMessages.setText(e.getMessage().toString());
						}
							
					}
				});
			}
		}).start();

	}

}