[
https://issues.apache.org/jira/browse/ARTEMIS-1095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francesco Nigro updated ARTEMIS-1095:
-------------------------------------
Description:
By default Netty uses the write buffer high/low water mark to perform flow
control while on the event loop.
Currently these properties are not set in Artemis, that is not being flow
controlled properly and is not seeing correct activation of the ReadyListener
on NettyConnection when it is considered writable.
I propose to define TransportConstants.NETTY_WRITE_BUFFER_LOW_WATER_MARK and
TransportConstants.NETTY_WRITE_BUFFER_HIGH_WATER_MARK to set the Netty's ones.
was:
By default Netty uses the write buffer high/low water mark to perform flow
control while on the event loop.
Currently these properties are not set in Artemis, that is not being flow
controlled properly and is not seeing correct activation of the ReadyListener
on NettyConnection when it is considered writable.
I propose to define TransportConstants..WRITE_BUFFER_LOW_WATER_MARK and
TransportConstants..WRITE_BUFFER_HIGH_WATER_MARK to set the Netty's ones.
> Netty's WriteBufferWaterMark configuration via TransportConstants to perform
> flow control
> -----------------------------------------------------------------------------------------
>
> Key: ARTEMIS-1095
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1095
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: Broker
> Reporter: Francesco Nigro
> Assignee: Francesco Nigro
> Priority: Minor
>
> By default Netty uses the write buffer high/low water mark to perform flow
> control while on the event loop.
> Currently these properties are not set in Artemis, that is not being flow
> controlled properly and is not seeing correct activation of the ReadyListener
> on NettyConnection when it is considered writable.
> I propose to define TransportConstants.NETTY_WRITE_BUFFER_LOW_WATER_MARK and
> TransportConstants.NETTY_WRITE_BUFFER_HIGH_WATER_MARK to set the Netty's ones.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
