Subversion Repositories SmartDukaan

package in.shop2020.thrift.clients;

import in.shop2020.serving.page.PageLoader.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 PageLoaderClient extends GenericServiceClient{

        private Client client = null;
        
        public PageLoaderClient(String clientIdentifier, String hostConfigKey,
                        String portConfigKey) throws Exception {
                super(clientIdentifier, hostConfigKey, portConfigKey);
                client = new Client(protocol);
                
        }
        
        public PageLoaderClient()throws Exception{
                this(PageLoaderClient.class.getSimpleName(), ConfigClientKeys.pageloader_service_hostname.toString(), ConfigClientKeys.pageloader_service_port.toString());
                if(transport.isOpen()){
                        Logger.log("Transport was already open", this);
                }else{
                        try {
                                transport.open();
                                Logger.log("Transport opened", this);
                        } catch (TTransportException e) {
                                Logger.log("Encountered exception while open transport "+ e, this);
                        }
                }
        }
        
        @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);
                }
        }
        
        public Client getClient(){
                if(!transport.isOpen()){
                        System.out.println("Transport is not open");
                        try {
                                
                                transport.open();
                        } catch (TTransportException e) {
                                e.printStackTrace();
                        }
                }
                return client;          
        }
        
        @PreDestroy
        private void closeTransport(){
                if(transport != null && transport.isOpen()){
                        Logger.log("Closing transport :", this);
                        transport.close();
                }
        }

}