diff options
| -rw-r--r-- | dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java index fd8cf3c1..7cb6ef19 100644 --- a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java +++ b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java @@ -15,12 +15,12 @@ import org.apache.thrift.protocol.TProtocolFactory; import org.apache.thrift.server.THsHaServer; import org.apache.thrift.server.TServer; import org.apache.thrift.server.TThreadPoolServer; -import org.apache.thrift.transport.TFramedTransport; import org.apache.thrift.transport.TNonblockingServerSocket; import org.apache.thrift.transport.TNonblockingServerTransport; import org.apache.thrift.transport.TServerSocket; import org.apache.thrift.transport.TServerTransport; import org.apache.thrift.transport.TTransportException; +import org.apache.thrift.transport.layered.TFastFramedTransport; import org.openslx.bwlp.sat.util.Identity; import org.openslx.bwlp.thrift.iface.SatelliteServer; import org.openslx.thrifthelper.TBinaryProtocolSafe; @@ -74,8 +74,8 @@ public class BinaryListener implements Runnable { args.protocolFactory(protFactory); args.processor(processor); args.minWorkerThreads(MINWORKERTHREADS).maxWorkerThreads(MAXWORKERTHREADS); - args.requestTimeout(2).requestTimeoutUnit(TimeUnit.MINUTES); - args.transportFactory(new TFramedTransport.Factory(MAX_MSG_LEN)); + args.stopTimeoutVal(2).stopTimeoutUnit(TimeUnit.MINUTES); + args.transportFactory(new TFastFramedTransport.Factory(MAX_MSG_LEN)); return new TThreadPoolServer(args); } |