10000 Silence deprecation warnings in Channel implementations · yezijiang/rabbitmq-java-client@5786af2 · GitHub
[go: up one dir, main page]

Skip to content

Commit 5786af2

Browse files
Silence deprecation warnings in Channel implementations
1 parent 4dc9801 commit 5786af2

File tree

2 files changed

+18
-0
lines changed

2 files changed

+18
-0
lines changed

src/com/rabbitmq/client/impl/ChannelN.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -137,14 +137,20 @@ public void clearReturnListeners() {
137137
returnListeners.clear();
138138
}
139139

140+
@SuppressWarnings("deprecation")
141+
@Deprecated
140142
public void addFlowListener(FlowListener listener) {
141143
flowListeners.add(listener);
142144
}
143145

146+
@SuppressWarnings("deprecation")
147+
@Deprecated
144148
public boolean removeFlowListener(FlowListener listener) {
145149
return flowListeners.remove(listener);
146150
}
147151

152+
@SuppressWarnings("deprecation")
153+
@Deprecated
148154
public void clearFlowListeners() {
149155
flowListeners.clear();
150156
}
@@ -1166,6 +1172,8 @@ public Confirm.SelectOk confirmSelect()
11661172
}
11671173

11681174
/** Public API - {@inheritDoc} */
1175+
@SuppressWarnings("deprecation")
1176+
@Deprecated
11691177
public boolean flowBlocked() {
11701178
return _blockContent;
11711179
}

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

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,8 @@ public void close(int closeCode, String closeMessage) throws IOException, Timeou
7373
}
7474
}
7575

76+
@SuppressWarnings("deprecation")
77+
@Deprecated
7678
public boolean flowBlocked() {
7779
return delegate.flowBlocked();
7880
}
@@ -100,16 +102,22 @@ public void clearReturnListeners() {
100102
delegate.clearReturnListeners();
101103
}
102104

105+
@SuppressWarnings("deprecation")
106+
@Deprecated
103107
public void addFlowListener(FlowListener listener) {
104108
this.flowListeners.add(listener);
105109
delegate.addFlowListener(listener);
106110
}
107111

112+
@SuppressWarnings("deprecation")
113+
@Deprecated
108114
public boolean removeFlowListener(FlowListener listener) {
109115
this.flowListeners.remove(listener);
110116
return delegate.removeFlowListener(listener);
111117
}
112118

119+
@SuppressWarnings("deprecation")
120+
@Deprecated
113121
public void clearFlowListeners() {
114122
this.flowListeners.clear();
115123
delegate.clearFlowListeners();
@@ -497,6 +505,8 @@ private void recoverConfirmListeners() {
497505
}
498506
}
499507

508+
@Deprecated
509+
@SuppressWarnings("deprecation")
500510
private void recoverFlowListeners() {
501511
for(FlowListener fl : this.flowListeners) {
502512
this.delegate.addFlowListener(fl);

0 commit comments

Comments
 (0)
0