Subversion Repositories SmartDukaan

package in.shop2020.alert.test;

import java.util.Date;

import in.shop2020.alert.AlertMapper;

import in.shop2020.alert.AlertService.Client;

import in.shop2020.alert.AlertServiceException;

import in.shop2020.alert.AlertType;

import in.shop2020.alert.EntityProcessedState;

import in.shop2020.alert.EntityType;

import in.shop2020.alert.MonitoredEntity;

import in.shop2020.alert.SearchFilter;

import org.apache.thrift.TException;

import org.apache.thrift.protocol.TBinaryProtocol;

import org.apache.thrift.protocol.TProtocol;

import org.apache.thrift.transport.TFramedTransport;

import org.apache.thrift.transport.TSocket;

import org.apache.thrift.transport.TTransport;

import org.apache.thrift.transport.TTransportException;

public class TestAlertServer {

	private static final int SOCKET_TIMEOUT = 1000 * 60 * 5;

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

		TSocket socket = new TSocket("localhost", 9018);

		socket.setTimeout(SOCKET_TIMEOUT);

		TTransport transport = new TFramedTransport(socket);

		TProtocol protocol = new TBinaryProtocol(transport);

		Client client = new Client(protocol);

		try {

			transport.open();

		} catch (TTransportException e) {

			e.printStackTrace();

		}

		try {

//			MonitoredEntity entity = new MonitoredEntity();

//			entity.setEntityType(EntityType.ORDER);

//			entity.setEventType(3);

//			entity.setEntityIdentifier("testing insertion");

//			entity.setWarnExpiryTime(new Date().UTC(2012, 6, 21, 18, 35, 0));

//			entity.setWarnExpiryTime(new Date().UTC(2012, 6, 22, 11, 45, 0));

//			entity.setDescription("Test Order entity");

//			entity.setEntityProcessedState(EntityProcessedState.WARNING_SENT);

//			client.scheduleAlert(entity);

//			client.updateMonitoredObject(entity);

//			client.endMonitoringEntity(EntityType.ORDER, "123");

//			client.deActivateEntityMonitoring(EntityType.ORDER);

//			client.activateEntityMonitoring(EntityType.ORDER, "amar.kumar@shop2020.in");

//			AlertMapper alertMap = new AlertMapper();

//			alertMap.setEntityType(EntityType.ORDER);

//			alertMap.setEventType(2);

//			alertMap.setEventdesciption("TEst");

//			alertMap.setAlertType(AlertType.EMAIL);

//			alertMap.setUserIds("amar.kumar@shop2020.in");

//			client.registerEventType(alertMap);

//			client.updateMonitoredObject(entity);

//			SearchFilter searchFilter = new SearchFilter();

//			searchFilter.setEntityProcessedState(EntityProcessedState.UNEXPIRED);

//			System.out.println(client.getEntities(searchFilter));

			System.out.println(client.getAlertMapper(EntityType.ORDER, 3));

		} catch (TException e) {

			e.printStackTrace();

		} catch (AlertServiceException ex) {

			ex.printStackTrace();

		}

	}

}