diff --git a/src/com/rabbitmq/client/Channel.java b/src/com/rabbitmq/client/Channel.java index e19cd3f2e8..0d24a6eb58 100644 --- a/src/com/rabbitmq/client/Channel.java +++ b/src/com/rabbitmq/client/Channel.java @@ -86,9 +86,9 @@ public interface Channel extends ShutdownNotifier { void close(int closeCode, String closeMessage) throws IOException, TimeoutException; /** - * Indicates whether the server has asked this client to stop - * sending content-bearing commands (such as basic.publish) by - * issueing a channel.flow{active=false}. + * Deprecated, superseded by TCP back pressure. + * @deprecated + * @see Resource-driven alarms */ boolean flowBlocked(); @@ -130,12 +130,18 @@ public interface Channel extends ShutdownNotifier { /** * Add a {@link FlowListener}. + * Deprecated, superseded by TCP back pressure. + * @deprecated + * @see Resource-driven alarms * @param listener the listener to add */ void addFlowListener(FlowListener listener); /** * Remove a {@link FlowListener}. + * Deprecated, superseded by TCP back pressure. + * @deprecated + * @see Resource-driven alarms * @param listener the listener to remove * @return true if the listener was found and removed, * false otherwise @@ -144,6 +150,9 @@ public interface Channel extends ShutdownNotifier { /** * Remove all {@link FlowListener}s. + * Deprecated, superseded by TCP back pressure. + * @deprecated + * @see Resource-driven alarms */ void clearFlowListeners();