* for a sessions' channel.
*/
@ThreadSafe
-final class ChannelOutputLimiter extends ChannelInboundHandlerAdapter {
+public final class ChannelOutputLimiter extends ChannelInboundHandlerAdapter {
private static final Logger LOG = LoggerFactory.getLogger(ChannelOutputLimiter.class);
private final BGPSessionImpl session;
private volatile boolean blocked;
}
}
- void write(final Notification msg) {
+ public void write(final Notification msg) {
ensureWritable();
this.session.write(msg);
}
return this.session.writeAndFlush(msg);
}
- void flush() {
+ public void flush() {
this.session.flush();
}