import java.util.ArrayList;
import android.app.Activity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.AdapterView;
import android.widget.ArrayAdapter;
import android.widget.Spinner;
public class MainActivity extends Activity implements
AdapterView.OnItemSelectedListener {
String itemValue;
Spinner spinnerOsversions;
public void addData() { }
public void onCreate(Bundle bundle) {
super.onCreate(bundle);
setContentView(R.layout.activity_main);
ArrayList arrayList = new ArrayList();
arrayList.add("Item 1");
arrayList.add("Item 2");
arrayList.add("Item 3");
arrayList.add("Item 4");
arrayList.add("Item 5");
spinnerOsversions = (Spinner) findViewById(R.id.spinner1);
ArrayAdapter arrayAdapter = new ArrayAdapter(this, R.layout.simplerow,
arrayList);
arrayAdapter.setDropDownViewResource(R.layout.simplerow);
spinnerOsversions.setAdapter(arrayAdapter);
spinnerOsversions
.setOnItemSelectedListener((AdapterView.OnItemSelectedListener) this);
}
public void onItemSelected(AdapterView<?> adapterView, View view, int n,
long l) {
spinnerOsversions.setSelection(n);
String selectedItem = spinnerOsversions.getSelectedItem().toString();
Log.d("selected item ===", selectedItem);
}
public void onNothingSelected(AdapterView<?> adapterView) {
}
} <?xml version="1.0" encoding="utf-8"?>
<TextView xmlns:android="http://schemas.android.com/apk/res/android"
android:id="@id/rowTextView"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:padding="10.0dip"
android:textSize="16.0sp" /> <?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="fill_parent"
android:layout_height="fill_parent"
android:orientation="vertical" >
<Spinner
android:id="@id/spinner1"
android:layout_width="fill_parent"
android:layout_height="wrap_content" />
</LinearLayout> 
import android.app.Activity;
import android.content.Context;
import android.content.Intent;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.os.Bundle;
import android.view.View;
import android.widget.AdapterView;
import android.widget.ArrayAdapter;
import android.widget.ListAdapter;
import android.widget.ListView;
import android.widget.Toast;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.List;
public class Accounts
extends Activity {
private static String DBNAME = "ROLLING.db";
String itemValue;
private ArrayAdapter<String> listAdapter;
private ListView mainListView;
SQLiteDatabase mydb;
@Override
public void onCreate(Bundle bundle) {
super.onCreate(bundle);
setContentView(R.layout.main_activity);
mainListView = (ListView)findViewById(R.id.list);
Object[] arrobject = new String[]{};
ArrayList arrayList = new ArrayList();
arrayList.addAll(Arrays.asList(arrobject));
listAdapter = new ArrayAdapter(this, R.layout.simplerow, arrayList);
listAdapter.add("Item 1 ");
listAdapter.add(Item 2);
listAdapter.add(Item 3);
listAdapter.add(Item 4);
listAdapter.add(Item 5);
mainListView.setAdapter(listAdapter);
mainListView.setOnItemClickListener((AdapterView.OnItemClickListener)new AdapterView.OnItemClickListener(){
public void onItemClick(AdapterView<?> adapterView, View view, int n, long l) {
itemValue = (String)mainListView.getItemAtPosition(n);
log.d("you clicked on ===", itemValue);
}
});
} <?xml version="1.0" encoding="utf-8"?>
<TextView xmlns:android="http://schemas.android.com/apk/res/android"
android:id="@id/rowTextView"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:padding="10.0dip"
android:textSize="16.0sp" /> <?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="fill_parent"
android:layout_height="fill_parent"
android:orientation="vertical" >
<ListView
android:id="@+id/list"
android:layout_width="fill_parent"
android:layout_height="fill_parent" />
</LinearLayout> 
private static String url_all_products = "http://vkcapp.in/app/get_all_products.php";
ArrayList<String>item1;
ArrayList<String>item2;
ArrayList<String>item3;
private static final String TAG_SUCCESS = "success";
private static final String TAG_PRODUCTS = "products";
JSONArray products = null;
// call this methode to invoke the connection to server new LoadAllProducts().execute();
class LoadAllProducts extends AsyncTask<String, String, String> {
/**
* Before starting background thread Show Progress Dialog
* */
@Override
protected void onPreExecute() {
super.onPreExecute();
pDialog = new ProgressDialog(DataFetching.this);
pDialog.setMessage("Updating products index. Please wait...");
pDialog.setIndeterminate(false);
pDialog.setCancelable(false);
pDialog.show();
item1=new ArrayList<String>();
item2=new ArrayList<String>();
item3=new ArrayList<String>();
}
/**
* getting All products from url
* */
protected String doInBackground(String... args) {
List<NameValuePair> params = new ArrayList<NameValuePair>();
params.add(new BasicNameValuePair("state", state));
Log.d("sateId======", state);
JSONObject json = jParser.makeHttpRequest(url_all_products, "POST", params);
try {
int success = json.getInt(TAG_SUCCESS);
if (success == 1) {
products = json.getJSONArray(TAG_PRODUCTS);
for (int i = 0; i < products.length(); i++) {
JSONObject c = products.getJSONObject(i);
item1.add(c.getString("item1"));
item2.add(c.getString("item2"));
item3.add(c.getString("item3"));
}
} else {
Intent i = new Intent(getApplicationContext(),
MainActivity.class);
// Closing all previous activities
i.addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
startActivity(i);
finish();
}
} catch (JSONException e) {
e.printStackTrace();
}
return null;
}
/**
* After completing background task Dismiss the progress dialog
* **/
protected void onPostExecute(String file_url) {
// dismiss the dialog after getting all products
runOnUiThread(new Runnable() {
public void run() {
// add something here to perform after recieving data such us updating listview
}
});
}
} 
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String args[]){
Socket s=null;
ServerSocket ss2=null;
System.out.println("Server Listening......");
try{
ss2 = new ServerSocket(4444); // can also use static final PORT_NUM , when defined
}
catch(IOException e){
e.printStackTrace();
System.out.println("Server error");
}
while(true){
try{
s= ss2.accept();
System.out.println("connection Established");
Reciever st=new Reciever(s);
st.start();
}
catch(Exception e){
e.printStackTrace();
System.out.println("Connection Error");
}
}
}
}//class ends import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
public class Sender {
private PrintWriter out;
public Sender(Socket clientSocket) {
try {
out = new PrintWriter(clientSocket.getOutputStream(), true);
} catch (IOException e) {
e.printStackTrace();
}
}
public void sendMessage(String message) {
out.println(message); // Print the message on output stream.
out.flush();
message="";
System.out.println("Server: " + message + "\n"); // Print the message on chat window.
}
} import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
class Reciever extends Thread{
String line=null;
BufferedReader is = null;
PrintWriter os=null;
Socket s=null;
public Reciever(Socket s){
this.s=s;
}
public void run() {
try{
is= new BufferedReader(new InputStreamReader(s.getInputStream()));
os=new PrintWriter(s.getOutputStream());
}catch(IOException e){
System.out.println("IO error in server thread");
}
try {
line=is.readLine();
while(line.compareTo("QUIT")!=0){
os.println(line);
os.flush();
if(line.equals("syncDb")){
DataHandler a = new DataHandler();
a.syncDb(s);
break;
}
else{
//
System.out.println("Response to Client : "+line);
line=is.readLine();
}
}
} catch (IOException e) {
line=this.getName(); //reused String line for getting thread name
System.out.println("IO Error/ Client "+line+" terminated abruptly");
}
catch(NullPointerException e){
line=this.getName(); //reused String line for getting thread name
System.out.println("Client "+line+" Closed");
}
finally{
try{
System.out.println("Connection Closing..");
if (is!=null){
is.close();
System.out.println(" Socket Input Stream Closed");
}
if(os!=null){
os.close();
System.out.println("Socket Out Closed");
}
if (s!=null){
s.close();
System.out.println("Socket Closed");
}
}
catch(IOException ie){
System.out.println("Socket Close Error");
}
}//end finally
}
} import java.net.Socket;
public class DataHandler {
public static void syncDb(Socket s) {
Sender sender = new Sender(s);
sender.sendMessage("***start***");
sender.sendMessage("This is a message from the server");
sender.sendMessage("***stop***");
}
} import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import android.app.Activity;
import android.app.ProgressDialog;
import android.os.AsyncTask;
import android.os.Build;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Toast;
public class MainActivity extends Activity {
private Socket client;
private PrintWriter printwriter;
private BufferedReader bufferedReader;
private ProgressDialog pDialog;
String host;
int port;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
}
/**
* This AsyncTask create the connection with the server and initialize the
* chat senders and receivers.
*/
private class ChatOperator extends AsyncTask<Void, Void, Void> {
@Override
protected Void doInBackground(Void... arg0) {
try {
client = new Socket(host, port); // Creating the
// server socket.
if (client != null) {
printwriter = new PrintWriter(client.getOutputStream(),
true);
InputStreamReader inputStreamReader = new InputStreamReader(
client.getInputStream());
bufferedReader = new BufferedReader(inputStreamReader);
} else {
System.out
.println("Server has not bean started on port 4444.");
}
} catch (UnknownHostException e) {
System.out.println("Faild to connect server " + host);
e.printStackTrace();
} catch (IOException e) {
System.out.println("Faild to connect server " + host);
e.printStackTrace();
}
return null;
}
/**
* Following method is executed at the end of doInBackground method.
*/
@Override
protected void onPostExecute(Void result) {
final Sender messageSender = new Sender(); // Initialize chat sender
// AsyncTask.
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.HONEYCOMB) {
messageSender.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
} else {
messageSender.execute();
}
Receiver receiver = new Receiver(); // Initialize chat receiver
// AsyncTask.
receiver.execute();
}
}
/**
* This AsyncTask continuously reads the input buffer and show the chat
* message if a message is availble.
*/
private class Receiver extends AsyncTask<Void, Void, Void> {
private String message;
@Override
protected Void doInBackground(Void... params) {
while (true) {
try {
if (bufferedReader.ready()) {
message = bufferedReader.readLine();
publishProgress(null);
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
try {
Thread.sleep(100);
} catch (InterruptedException ie) {
}
}
}
@Override
protected void onProgressUpdate(Void... values) {
try {
Toast.makeText(getApplicationContext(),
"Received message: "+message, Toast.LENGTH_LONG).show();
} catch (Exception e) {
// TODO: handle exception
}
}
}
/**
* This AsyncTask sends the chat message through the output stream.
*/
private class Sender extends AsyncTask<Void, Void, Void> {
@Override
protected Void doInBackground(Void... params) {
printwriter.write("message from client" + "\n");
printwriter.flush();
Log.d("message", "send");
return null;
}
@Override
protected void onPostExecute(Void result) {
}
}
public void LoadAndSave(View v) {
pDialog = new ProgressDialog(MainActivity.this);
pDialog.setMessage("Loading meassage. Please wait...");
pDialog.setIndeterminate(false);
pDialog.setCancelable(false);
pDialog.show();
ChatOperator chatOperator = new ChatOperator();
chatOperator.execute();
}
}// activity ends <ScrollView xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="fill_parent"
android:layout_height="fill_parent"
>
<TableLayout
android:layout_width="fill_parent"
android:layout_height="172dp"
android:stretchColumns="1" >
<Button
android:id="@+id/button1"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:layout_marginBottom="20dp"
android:layout_marginTop="20dp"
android:onClick="LoadAndSave"
android:text="send a message to server" />
</TableLayout>
</ScrollView> 
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.logging.Handler;
import javax.mail.Address;
import javax.mail.BodyPart;
import javax.mail.Flags;
import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.NoSuchProviderException;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Store;
import javax.mail.Flags.Flag;
import javax.mail.search.FlagTerm;
public class ReceiveMail {
Properties properties = null;
private Session session = null;
private Store store = null;
private Folder inbox = null;
private String userName = "XXXXXX@XXXXXX.com";// provide user name
private String password = "XXXXXXXXXX";// provide password
public ReceiveMail() {
}
public void readMails() {
properties = new Properties();
properties.setProperty("mail.host", "imap.gmail.com");
properties.setProperty("mail.port", "995");
properties.setProperty("mail.transport.protocol", "imaps");
session = Session.getInstance(properties,
new javax.mail.Authenticator() {
protected PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication(userName, password);
}
});
try {
store = session.getStore("imaps");
store.connect();
inbox = store.getFolder("INBOX");
inbox.open(Folder.READ_WRITE);
// search for all "unseen" messages
Flags seen = new Flags(Flags.Flag.SEEN);
FlagTerm unseenFlagTerm = new FlagTerm(seen, false);
Message messages[] = inbox.search(unseenFlagTerm);
// Message messages[] = inbox.search(new FlagTerm(
// new Flags(Flag.RECENT), false));
//
System.out.println("Number of mails = " + messages.length);
for (int i = 0; i < messages.length; i++) {
Message message = messages[i];
Address[] from = message.getFrom();
System.out.println("-------------------------------");
System.out.println("Date : " + message.getSentDate());
System.out.println("From : " + from[0]);
System.out.println("Subject: " + message.getSubject());
System.out.println("Content : ");
processMessageBody(message);
System.out.println("--------------------------------");
}
inbox.close(true);
store.close();
} catch (NoSuchProviderException e) {
e.printStackTrace();
} catch (MessagingException e) {
//e.printStackTrace();
System.out.println("please connect to internet!");
}
}
public void processMessageBody(Message message) {
try {
Object content = message.getContent();
// check for string
// then check for multipart
if (content instanceof String) {
System.out.println(content);
} else if (content instanceof Multipart) {
Multipart multiPart = (Multipart) content;
procesMultiPart(multiPart);
} else if (content instanceof InputStream) {
InputStream inStream = (InputStream) content;
int ch;
while ((ch = inStream.read()) != -1) {
System.out.write(ch);
} }
} catch (IOException e) {
e.printStackTrace();
} catch (MessagingException e) {
e.printStackTrace();
}
}
public void procesMultiPart(Multipart content) {
try {
int multiPartCount = content.getCount();
for (int i = 0; i < multiPartCount; i++) {
BodyPart bodyPart = content.getBodyPart(i);
Object o;
o = bodyPart.getContent();
if (o instanceof String) {
String[] splited = o.toString().split("<div");
String msg = splited[0];
if(!msg.equals(""))
System.out.println(msg);
} else if (o instanceof Multipart) {
procesMultiPart((Multipart) o);
}
}
} catch (IOException e) {
e.printStackTrace();
} catch (MessagingException e) {
e.printStackTrace();
}
}
public static void notifier(){
Runnable helloRunnable = new Runnable() {
public void run() {
// System.out.println("Hello world");
ReceiveMail sample = new ReceiveMail();
sample.readMails();
}
};
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
executor.scheduleAtFixedRate(helloRunnable, 0, 3, TimeUnit.SECONDS);
}
public static void main(String[] args) {
notifier();
}
}