diff options
| -rw-r--r-- | src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java b/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java index fab1e05..7c20202 100644 --- a/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java +++ b/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java @@ -12,13 +12,13 @@ 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.TSSLTransportFactory; import org.apache.thrift.transport.TSSLTransportFactory.TSSLTransportParameters; import org.apache.thrift.transport.TServerTransport; import org.apache.thrift.transport.TTransportException; +import org.apache.thrift.transport.layered.TFramedTransport; import org.openslx.bwlp.thrift.iface.MasterServer; import org.openslx.imagemaster.Globals; import org.openslx.thrifthelper.TBinaryProtocolSafe; @@ -79,7 +79,7 @@ public class BinaryListener implements Runnable args.protocolFactory( protFactory ); args.processor( processor ); args.minWorkerThreads( 4 ).maxWorkerThreads( 256 ); - args.requestTimeout( 2 ).requestTimeoutUnit( TimeUnit.MINUTES ); + args.stopTimeoutVal( 2 ).stopTimeoutUnit( TimeUnit.MINUTES ); args.transportFactory( new TFramedTransport.Factory( MAX_MSG_LEN ) ); return new TThreadPoolServer( args ); } |