package org.tango.usereventtest;

import java.util.Scanner;

import org.tango.server.events.EventType;

import fr.esrf.Tango.DevFailed;
import fr.esrf.TangoApi.ApiUtil;
import fr.esrf.TangoApi.DeviceAttribute;
import fr.esrf.TangoApi.DeviceProxy;
import fr.esrf.TangoApi.events.TangoUser;


public class UserEventTestClient {


	static UserEventCallBack callBack = new UserEventCallBack();
	static int event_id = 0;		
	static String[] filters = new String[0];


	public static void executeCommand() throws DevFailed
	{
		DeviceProxy devproxy;
		devproxy = new DeviceProxy("usr/evt/tst");
		DeviceAttribute a;		
		a = devproxy.read_attribute("number");
		event_id = devproxy.subscribe_event("number", TangoUser.USER_EVENT, callBack , filters);
		System.out.println("The event id is " + event_id);
		System.out.println("This is the value : " + a.extractDouble());

	}

	public static void main(String[] args) throws DevFailed {

		ApiUtil.set_asynch_cb_sub_model(0);
		Scanner in = new Scanner(System.in);
		boolean flag = true;

		while(flag){
			System.out.println("Please enter 1 to start client: ");
			int choice = in.nextInt();
			if(choice ==1)
			{
				executeCommand();
			}
			else
			{
				System.out.println("Please check the given input!");
				flag=true;
			}
		}
	}
}