We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6b3f51c commit b0dcf24Copy full SHA for b0dcf24
src/com/rabbitmq/client/impl/ChannelN.java
@@ -247,8 +247,12 @@ public void releaseChannelNumber() {
247
Consumer callback = _consumers.get(m.consumerTag);
248
if (callback == null) {
249
if (defaultConsumer == null) {
250
- // No handler set, ignore.
251
- return true;
+ // No handler set. We should blow up as this message
+ // needs acking, just dropping it is not enough. See bug
252
+ // 22587 for discussion.
253
+ throw new IllegalStateException("Unsolicited delivery -" +
254
+ " see Channel.setDefaultConsumer to handle this" +
255
+ " case.");
256
}
257
else {
258
callback = defaultConsumer;
0 commit comments