From 64ea92982ec1755fb6e9b8eaf50927f33a76d926 Mon Sep 17 00:00:00 2001 From: Nino Breuer Date: Thu, 20 Nov 2014 14:57:00 +0100 Subject: • new package for thrift classes --- .../src/main/java/thrift/ThriftConnection.java | 56 ++++++++++++++++++++++ 1 file changed, 56 insertions(+) create mode 100644 dozentenmodulserver/src/main/java/thrift/ThriftConnection.java (limited to 'dozentenmodulserver/src/main/java/thrift/ThriftConnection.java') diff --git a/dozentenmodulserver/src/main/java/thrift/ThriftConnection.java b/dozentenmodulserver/src/main/java/thrift/ThriftConnection.java new file mode 100644 index 00000000..4a01b85a --- /dev/null +++ b/dozentenmodulserver/src/main/java/thrift/ThriftConnection.java @@ -0,0 +1,56 @@ +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.apache.thrift.transport.TTransportException; + +import server.generated.Server; +import server.generated.Server.Client; + +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); + + public ThriftConnection() { + // TODO Auto-generated constructor stub + } + + public Client getThriftConnection() + { + + try { + transport.open(); + } catch (TTransportException e) { + LOGGER.error("Keine Verbindung möglich! Satellit: " + satAddress); + e.printStackTrace(); + 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."); + + return client; + } + + public void closeThriftConnection() + { + LOGGER.info("Verbindung wird geplant getrennt."); + transport.close(); + } +} + \ No newline at end of file -- cgit v1.2.3-55-g7522