summaryrefslogtreecommitdiff
path: root/lib/java/src/org/apache/thrift/transport/TEndpointTransport.java
diff options
context:
space:
mode:
Diffstat (limited to 'lib/java/src/org/apache/thrift/transport/TEndpointTransport.java')
-rw-r--r--lib/java/src/org/apache/thrift/transport/TEndpointTransport.java7
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);