package pt.ubiwhere.android.consume;


import android.app.Activity;
import android.os.Bundle;
import android.os.StrictMode;
import android.os.StrictMode.ThreadPolicy;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.RadioButton;
import android.widget.Toast;
import pk.aamir.stompj.Connection;
import pk.aamir.stompj.Message;
import pk.aamir.stompj.MessageHandler;
import pk.aamir.stompj.StompJException;


public class ConsumeActivity extends Activity {
    /** Called when the activity is first created. */
	private EditText text;
	
	@Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        text = (EditText) findViewById(R.id.editText1);
        ThreadPolicy tp = ThreadPolicy.LAX;
        StrictMode.setThreadPolicy(tp);
        consumeMessages();
      }
    
	// Receive msg from the queue
	private void consumeMessages() {
		
		Connection con = new Connection("192.168.2.244", 61613, "system", "manager");
		try {
			con.connect();
			con.subscribe("/queue/a",true);
			con.addMessageHandler("/queue/a", new MessageHandler() {
	            public void onMessage(Message msg) {
	               text.setText(msg.getContentAsString());
	            }

			});
		} catch (StompJException e) {
			
			e.printStackTrace();
		}
		con.disconnect();
		
	}
}