diff options
| author | Simon Rettberg | 2014-09-13 13:55:37 +0200 |
|---|---|---|
| committer | Simon Rettberg | 2014-09-13 13:55:37 +0200 |
| commit | 93275e45ae069584bbba9d9791d477910385f7b9 (patch) | |
| tree | d3b6f69d420d6f11c01ca4f6fcb3b78e357c96b7 /dozentenmodul/src/main/java/thrift/MasterThriftConnection.java | |
| parent | [client] use TFramedTransport for master-server Connection (diff) | |
| download | tutor-module-93275e45ae069584bbba9d9791d477910385f7b9.tar.gz tutor-module-93275e45ae069584bbba9d9791d477910385f7b9.tar.xz tutor-module-93275e45ae069584bbba9d9791d477910385f7b9.zip | |
[client] MAsterserver thrift connection: Set connection timeout of 6 secs
Diffstat (limited to 'dozentenmodul/src/main/java/thrift/MasterThriftConnection.java')
| -rw-r--r-- | dozentenmodul/src/main/java/thrift/MasterThriftConnection.java | 24 |
1 files changed, 11 insertions, 13 deletions
diff --git a/dozentenmodul/src/main/java/thrift/MasterThriftConnection.java b/dozentenmodul/src/main/java/thrift/MasterThriftConnection.java index 0ff6f7bd..eec1d785 100644 --- a/dozentenmodul/src/main/java/thrift/MasterThriftConnection.java +++ b/dozentenmodul/src/main/java/thrift/MasterThriftConnection.java @@ -8,18 +8,17 @@ import org.apache.thrift.transport.TTransport; import org.apache.thrift.transport.TTransportException; import org.openslx.imagemaster.thrift.iface.ImageServer.Client; +public class MasterThriftConnection { + public static final String MASTERSERVER_IP = "132.230.4.16"; + public static final int MASTERSERVER_PORT = 9090; + public static final int MASTERSERVER_TIMEOUT_MS = 6000; + + final TTransport transport = new TFramedTransport(new TSocket( + MASTERSERVER_IP, MASTERSERVER_PORT, MASTERSERVER_TIMEOUT_MS)); + + public Client getMasterThriftConnection() { -public class MasterThriftConnection { - - public static final String MASTERSERVERIP="132.230.4.16"; - //public static final String MASTERSERVERIP="127.0.0.1"; - - final TTransport transport = new TFramedTransport ( new TSocket(MASTERSERVERIP, 9090) ); - - public Client getMasterThriftConnection() - { - try { transport.open(); } catch (TTransportException e) { @@ -30,12 +29,11 @@ public class MasterThriftConnection { final TProtocol protocol = new TBinaryProtocol(transport); final Client client = new Client(protocol); System.out.println("Masterserver erreichbar."); - + return client; } - public void closeMasterThriftConnection() - { + public void closeMasterThriftConnection() { transport.close(); } } |