Subversion Repositories SmartDukaan

package in.shop2020.thrift.clients;

import in.shop2020.utils.ConfigClientKeys;
import in.shop2020.utils.Logger;
import in.shop2020.warehouse.WarehouseService.Client;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;

import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransportException;

public class WarehouseServiceClient extends GenericServiceClient {

    private Client client = null;
    
    public WarehouseServiceClient(String clientIdentifier,
            String hostConfigKey, String portConfigKey) throws Exception {
        super(clientIdentifier, hostConfigKey, portConfigKey);
        client = new Client(protocol);
        
    }
    
    public WarehouseServiceClient() throws Exception{
        this(WarehouseServiceClient.class.getSimpleName(),
                ConfigClientKeys.warehouse_service_server_host.toString(),
                ConfigClientKeys.warehouse_service_server_port.toString());
        if(transport.isOpen()){
            Logger.log("Transport was already open", this);
        }
        try {
            transport.open();
            Logger.log("Transport opened", this);
        } catch (TTransportException e) {
            Logger.log("Encountered exception while opening transport: ", e);
        }
    }
    
    @PostConstruct
    private 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(){
        return client;
    }

    @Override
    public void closeSession() {
        return;
    }
}