Subversion Repositories SmartDukaan

Rev

Rev 376 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 376 Rev 402
Line 7... Line 7...
7 
import javax.annotation.PostConstruct;
 7 
import javax.annotation.PostConstruct;
8 
import javax.annotation.PreDestroy;
 8 
import javax.annotation.PreDestroy;
9 
 
 9 
 
10 
import org.apache.thrift.transport.TTransportException;
 10 
import org.apache.thrift.transport.TTransportException;
11 
 
 11 
 
12 
public class PageLoaderClient extends GenericServiceJavaClient{
 12 
public class PageLoaderClient extends GenericServiceClient{
13 
 
 13 
 
14 
	private Client client = null;
 14 
	private Client client = null;
15
15
16 
	public PageLoaderClient(String clientIdentifier, String hostConfigKey,
 16 
	public PageLoaderClient(String clientIdentifier, String hostConfigKey,
17 
			String portConfigKey) throws Exception {
 17 
			String portConfigKey) throws Exception {
Line 22... Line 22...
22
22
23 
	public PageLoaderClient()throws Exception{
 23 
	public PageLoaderClient()throws Exception{
24 
		this(PageLoaderClient.class.getSimpleName(), ConfigClientKeys.pageloader_service_hostname.toString(), ConfigClientKeys.pageloader_service_port.toString());
 24 
		this(PageLoaderClient.class.getSimpleName(), ConfigClientKeys.pageloader_service_hostname.toString(), ConfigClientKeys.pageloader_service_port.toString());
25 
		if(transport.isOpen()){
 25 
		if(transport.isOpen()){
26 
			Logger.log("Transport was already open", this);
 26 
			Logger.log("Transport was already open", this);
27 
		}
 27 
		}else{
28 
		try {
 28 
			try {
29 
			transport.open();
 29 
				transport.open();
30 
			Logger.log("Transport opened", this);
 30 
				Logger.log("Transport opened", this);
31 
		} catch (TTransportException e) {
 31 
			} catch (TTransportException e) {
32 
			Logger.log("Encountered exception while open transport "+ e, this);
 32 
				Logger.log("Encountered exception while open transport "+ e, this);
- 
 
 33 
			}
33 
		}
 34 
		}
34 
	}
 35 
	}
35
36
36 
	@PostConstruct
 37 
	@PostConstruct
37 
	private void openTransport(){
 38 
	private void openTransport(){
Line 44... Line 45...
44 
			Logger.log("Encountered exception while open transport "+ e, this);
 45 
			Logger.log("Encountered exception while open transport "+ e, this);
45 
		}
 46 
		}
46 
	}
 47 
	}
47
48
48 
	public Client getClient(){
 49 
	public Client getClient(){
- 
 
 50 
		if(!transport.isOpen()){
- 
 
 51 
			System.out.println("Transport is not open");
- 
 
 52 
			try {
- 
 
 53
- 
 
 54 
				transport.open();
- 
 
 55 
			} catch (TTransportException e) {
- 
 
 56 
				e.printStackTrace();
- 
 
 57 
			}
- 
 
 58 
		}
49 
		return client;
 59 
		return client;
50 
	}
 60 
	}
51
61
52 
	@PreDestroy
 62 
	@PreDestroy
53 
	private void closeTransport(){
 63 
	private void closeTransport(){
54 
		if(transport != null && transport.isOpen()){
 64 
		if(transport != null && transport.isOpen()){