1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
package thrift;
import javax.swing.JOptionPane;
import models.SessionData;
import org.apache.log4j.Logger;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.openslx.sat.thrift.iface.Server;
import org.openslx.sat.thrift.iface.Server.Client;
import org.openslx.sat.thrift.version.Version;
public class ThriftConnection {
private final static Logger LOGGER = Logger
.getLogger(ThriftConnection.class);
private String satAddress = SessionData.session.getServerAdress();
final TTransport transport = new TSocket(satAddress, 9090, 10000);
public Client getThriftConnection() {
try {
transport.open();
} catch (Exception e) {
LOGGER.error("Keine Verbindung möglich! Satellit: " + satAddress, e);
JOptionPane.showMessageDialog(null,
"Konnte keine Verbindung zum Satellit '" + satAddress
+ "' aufbauen!", "Debug-Message",
JOptionPane.ERROR_MESSAGE);
return null;
}
final TProtocol protocol = new TBinaryProtocol(transport);
final Server.Client client = new Server.Client(protocol);
LOGGER.info("Verbindung zu " + satAddress + " wurde aufgebaut.");
long remoteVersion;
try {
remoteVersion = client.getVersion();
} catch (Exception e) {
LOGGER.error(
"Could not query sat server version after successful connect! Assuming untagged version 1",
e);
remoteVersion = 1;
}
String text = null;
if (remoteVersion > Version.VERSION) {
text = "Das von Ihnen verwendete Dozentenmodul ist zu alt, um mit dem Satelliten-Server zu verbinden.\n"
+ "Sie verwenden Version "
+ Version.VERSION
+ ", der Satellit "
+ remoteVersion
+ "\n"
+ "Aktuelle Version unter http://bwlehrpool.hs-offenburg.de/";
} else if (remoteVersion < Version.VERSION) {
text = "Das von Ihnen verwendete Dozentenmodul ist zu neu, um mit dem Satelliten-Server zu verbinden.\n"
+ "Sie verwenden Version "
+ Version.VERSION
+ ", der Satellit " + remoteVersion;
}
if (text != null) {
JOptionPane.showMessageDialog(null, text, "Fehler",
JOptionPane.ERROR_MESSAGE);
}
return client;
}
public void closeThriftConnection() {
LOGGER.info("Verbindung wird geplant getrennt.");
transport.close();
}
}
|
