Page History

...

capacity: size in bytes at which the queue is thought to be full (and thus publishes which send messages which take the total queue size above this mark will be blocked).  Default 0 (no maximum)
flowResumeCapacity: the queue size at which producers are unflowed (defaulted to capacity)

...

    public boolean dispatchChannelFlow(ChannelFlowBody body, int channelId) throws AMQException
    {
        _channelFlowMethodHandler.methodReceived(_session, body, channelId);
        return true;
    }

Logging

Additionally logging messages should be emitted

1) on the broker each time the queue issues an overfull request to a session to start flow control
2) on the client every time it receives a flow control command from the broker
3) on the client every time it attempts to send a message but finds itself blocked by broker flow control - in particular this message should repeat periodically untill the message is sent