diff options
Diffstat (limited to 'lib/java/src/org/apache/thrift/transport/TEndpointTransport.java')
-rw-r--r-- | lib/java/src/org/apache/thrift/transport/TEndpointTransport.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/lib/java/src/org/apache/thrift/transport/TEndpointTransport.java b/lib/java/src/org/apache/thrift/transport/TEndpointTransport.java index f32efae90..f33b8b72d 100644 --- a/lib/java/src/org/apache/thrift/transport/TEndpointTransport.java +++ b/lib/java/src/org/apache/thrift/transport/TEndpointTransport.java @@ -26,15 +26,20 @@ public abstract class TEndpointTransport extends TTransport{ protected long getMaxMessageSize() { return getConfiguration().getMaxMessageSize(); } + public int getMaxFrameSize() { return getConfiguration().getMaxFrameSize(); } + + public void setMaxFrameSize(int maxFrameSize) { getConfiguration().setMaxFrameSize(maxFrameSize); } + protected long knownMessageSize; protected long remainingMessageSize; private TConfiguration _configuration; + public TConfiguration getConfiguration() { return _configuration; } - public TEndpointTransport( TConfiguration config) throws TTransportException { + public TEndpointTransport(TConfiguration config) throws TTransportException { _configuration = Objects.isNull(config) ? new TConfiguration() : config; resetConsumedMessageSize(-1); |