Skip to content

Commit c5115fd

Browse files
author
Alexandru Scvortov
committed
dead-lettering to self no longer works
1 parent 76450dd commit c5115fd

File tree

1 file changed

+0
-31
lines changed

1 file changed

+0
-31
lines changed

test/src/com/rabbitmq/client/test/functional/DeadLetterExchange.java

Lines changed: 0 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -219,37 +219,6 @@ public void process(GetResponse getResponse) {
219219
});
220220
}
221221

222-
public void testDeadLetterSelf() throws Exception {
223-
channel.queueDelete(DLQ);
224-
declareQueue(DLQ, DLX, null, null);
225-
226-
declareQueue(DLX);
227-
228-
channel.queueBind(TEST_QUEUE_NAME, "amq.direct", "test");
229-
channel.queueBind(DLQ, DLX, "test");
230-
231-
publishN(MSG_COUNT_MANY, PropertiesFactory.NULL);
232-
233-
channel.queuePurge(TEST_QUEUE_NAME);
234-
sleep(100);
235-
channel.queuePurge(DLQ);
236-
237-
// The messages have been purged once from TEST_QUEUE_NAME and
238-
// once from DLQ.
239-
consumeN(DLQ, MSG_COUNT_MANY, new WithResponse() {
240-
@SuppressWarnings("unchecked")
241-
public void process(GetResponse getResponse) {
242-
Map<String, Object> headers = getResponse.getProps().getHeaders();
243-
assertNotNull(headers);
244-
ArrayList<Object> death = (ArrayList<Object>)headers.get("x-death");
245-
assertNotNull(death);
246-
assertEquals(2, death.size());
247-
assertDeathReason(death, 0, DLQ, "queue_purged");
248-
assertDeathReason(death, 1, TEST_QUEUE_NAME, "queue_purged");
249-
}
250-
});
251-
}
252-
253222
public void testDeadLetterNewRK() throws Exception {
254223
declareQueue(TEST_QUEUE_NAME, DLX, "test-other", null);
255224

0 commit comments

Comments
 (0)