how to use GlobalTrafficShapingHandler for the mqtt server？

[ljwhx2002]

Questions

we can use the trafficHandler on netty pipeline，buy it is unvisiable in the mqttserver。

such as:
trafficHandler = new GlobalTrafficShapingHandler(xxx);
ChannelPipeline pipeline = pipeline();
pipeline.addLast("global-traffic-shaping", trafficHandler);

unfortunately, the pipeline is unvisiable in the mqttserver.

can I get the pipeline by someway?

[vietj]

we could have an extension point of that @ljwhx2002

[shblue21]

I think this use case is now covered by Vert.x Core's TrafficShapingOptions.

Since MqttServerOptions extends NetServerOptions, traffic shaping can be configured without accessing the Netty pipeline directly.

MqttServerOptions options = new MqttServerOptions();

options.setTrafficShapingOptions(new TrafficShapingOptions()
  .setInboundGlobalBandwidth(64 * 1024)
  .setOutboundGlobalBandwidth(128 * 1024));

MqttServer server = MqttServer.create(vertx, options);