org.apache.qpid.proton.engine.Transport.setInitialRemoteMaxFrameSize()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(1.6k)|赞(0)|评价(0)|浏览(100)

本文整理了Java中org.apache.qpid.proton.engine.Transport.setInitialRemoteMaxFrameSize()方法的一些代码示例,展示了Transport.setInitialRemoteMaxFrameSize()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Transport.setInitialRemoteMaxFrameSize()方法的具体详情如下:
包路径:org.apache.qpid.proton.engine.Transport
类名称:Transport
方法名:setInitialRemoteMaxFrameSize

Transport.setInitialRemoteMaxFrameSize介绍

[英]Allows overriding the initial remote-max-frame-size to a value greater than the default 512bytes. The value set will be used until such time as the Open frame arrives from the peer and populates the remote max frame size. This method must be called before before #sasl() in order to influence SASL behaviour.
[中]允许将初始远程最大帧大小覆盖为大于默认512字节的值。在打开的帧从对等方到达并填充远程最大帧大小之前,将使用该值集。为了影响sasl行为,必须在#sasl()之前调用此方法。

代码示例

代码示例来源:origin: EnMasseProject/enmasse

@Override
public void init(final NetSocket socket,
         final ProtonConnection protonConnection,
         final Transport transport) {
  // allow for frames bigger than 512 bytes to support mechanisms that send (for instance) tokens
  transport.setInitialRemoteMaxFrameSize(1024*1024);
  this.sasl = transport.sasl();
  sasl.server();
  sasl.allowSkip(false);
  sasl.setMechanisms(getValidMechanisms(getPasswordHashAlgorithms()));
  connection = protonConnection;
}

代码示例来源:origin: org.apache.activemq/artemis-amqp-protocol

transport.setInitialRemoteMaxFrameSize(protocolManager.getInitialRemoteMaxFrameSize());
transport.setMaxFrameSize(maxFrameSize);
transport.setOutboundFrameSizeLimit(maxFrameSize);

代码示例来源:origin: apache/activemq-artemis

transport.setInitialRemoteMaxFrameSize(protocolManager.getInitialRemoteMaxFrameSize());
transport.setMaxFrameSize(maxFrameSize);
transport.setOutboundFrameSizeLimit(maxFrameSize);

相关文章