Subversion Repositories SmartDukaan

package in.shop2020.thrift.clients;

import in.shop2020.model.v1.shoppingcart.ShoppingCartService.Client;

import in.shop2020.utils.ConfigClientKeys;

import in.shop2020.utils.Logger;

import javax.annotation.PostConstruct;

import javax.annotation.PreDestroy;

import org.apache.thrift.transport.TTransportException;

public class ShoppingCartClient extends GenericServiceClient{

	private Client client = null;

	public ShoppingCartClient(String clientIdentifier,

			String hostConfigKey, String portConfigKey) throws Exception {

		super(clientIdentifier, hostConfigKey, portConfigKey);

		client = new Client(protocol);

	}

	public ShoppingCartClient() throws Exception{

		this(ShoppingCartClient.class.getSimpleName(), ConfigClientKeys.shopping_cart_server_host.toString(), ConfigClientKeys.shopping_cart_server_port.toString());

	}

	@PostConstruct

	public void openTransport(){

		if(transport.isOpen()){

			Logger.log("Transport was already open", this);

		}

		try {

			transport.open();

		} catch (TTransportException e) {

			Logger.log("Encountered exception while open transport "+ e, this);

		}

	}

	@PreDestroy

	private void closeTransport(){

		if(transport != null && transport.isOpen()){

			Logger.log("Closing transport :", this);

			transport.close();

		}

	}

	public Client getClient(){

		if(!transport.isOpen()){

			System.out.println("Transport is not open");

			try {

				transport.open();

			} catch (TTransportException e) {

				e.printStackTrace();

			}

		}

		return client;

	}

}