Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[AMQ-8412] - Add some comments for maxFrameSizeEnabled

This commit is contained in:
Christopher L. Shannon (cshannon) 2022-02-07 08:45:28 -05:00
parent fb036974ca
commit 19949e36bc
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-client/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java
View File

@ -621,6 +621,12 @@ public final class OpenWireFormat implements WireFormat {
return maxFrameSizeEnabled; return maxFrameSizeEnabled;
} }
/**
* Set whether the maxFrameSize check will be enabled. Note this is only applied to this format
* and will NOT be negotiated
*
* @param maxFrameSizeEnabled
*/
public void setMaxFrameSizeEnabled(boolean maxFrameSizeEnabled) { public void setMaxFrameSizeEnabled(boolean maxFrameSizeEnabled) {
this.maxFrameSizeEnabled = maxFrameSizeEnabled; this.maxFrameSizeEnabled = maxFrameSizeEnabled;
} }
@ -636,6 +642,7 @@ public final class OpenWireFormat implements WireFormat {
this.setMaxFrameSize(min(preferedWireFormatInfo.getMaxFrameSize(), info.getMaxFrameSize())); this.setMaxFrameSize(min(preferedWireFormatInfo.getMaxFrameSize(), info.getMaxFrameSize()));
info.setMaxFrameSize(this.getMaxFrameSize()); info.setMaxFrameSize(this.getMaxFrameSize());
//Note: Don't negotiate maxFrameSizeEnabled so the client and server can set independently
this.stackTraceEnabled = info.isStackTraceEnabled() && preferedWireFormatInfo.isStackTraceEnabled(); this.stackTraceEnabled = info.isStackTraceEnabled() && preferedWireFormatInfo.isStackTraceEnabled();
info.setStackTraceEnabled(this.stackTraceEnabled); info.setStackTraceEnabled(this.stackTraceEnabled);

6
activemq-client/src/main/java/org/apache/activemq/openwire/OpenWireFormatFactory.java
View File

@ -207,6 +207,12 @@ public class OpenWireFormatFactory implements WireFormatFactory {
this.includePlatformDetails = includePlatformDetails; this.includePlatformDetails = includePlatformDetails;
} }
/**
* Set whether the maxFrameSize check will be enabled. Note this is only applied to this factory
* and will NOT be negotiated
*
* @param maxFrameSizeEnabled
*/
public void setMaxFrameSizeEnabled(boolean maxFrameSizeEnabled) { public void setMaxFrameSizeEnabled(boolean maxFrameSizeEnabled) {
this.maxFrameSizeEnabled = maxFrameSizeEnabled; this.maxFrameSizeEnabled = maxFrameSizeEnabled;
} }