package thrift; import javax.swing.JOptionPane; import models.SessionData; 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.apache.thrift.transport.TTransportException; import server.Server; import server.Server.Client; public class ThriftConnection { private String satAddress = ""+SessionData.session.getServerAdress(); final TTransport transport = new TSocket(satAddress, 9090); public ThriftConnection() { // TODO Auto-generated constructor stub } public Client getThriftConnection() { try { transport.open(); } catch (TTransportException e) { System.out.println("Keine Verbindung m\u00f6glich! Satellit="+satAddress); e.printStackTrace(); JOptionPane.showMessageDialog(null, e.getCause()+"\n"+e.getMessage(), "Debug-Message", JOptionPane.ERROR_MESSAGE); //System.out.println("Keine Verbindung moeglich! Satellit="); return null; } final TProtocol protocol = new TBinaryProtocol(transport); final Server.Client client = new Server.Client(protocol); System.out.println("Verbindung zu "+satAddress+" wurde aufgebaut."); return client; } public void closeThriftConnection() { System.out.println("Verbindung wird geplant getrennt..."); transport.close(); } }