Skip to content

Commit 7b28875

Browse files
Sync with changes in default
1 parent 9cf0def commit 7b28875

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

src/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -70,12 +70,9 @@ public void close(int closeCode, String closeMessage) throws IOException {
7070
}
7171
}
7272

73-
public AMQP.Channel.FlowOk flow(boolean active) throws IOException {
74-
return delegate.flow(active);
75-
}
76-
77-
public AMQP.Channel.FlowOk getFlow() {
78-
return delegate.getFlow();
73+
@Override
74+
public boolean flowBlocked() {
75+
return delegate.flowBlocked();
7976
}
8077

8178
public void abort() throws IOException {

0 commit comments

Comments
 (0)