Skip to content

Commit e0e92b7

Browse files
committed
merge default into bug24725
2 parents 615ed42 + a57fc4b commit e0e92b7

File tree

2 files changed

+17
-24
lines changed

2 files changed

+17
-24
lines changed

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

Lines changed: 16 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -63,15 +63,18 @@ protected void setUp() throws IOException {
6363
"confirm-multiple-queues");
6464
}
6565

66-
public void testTransient()
67-
throws IOException, InterruptedException {
68-
confirmTest("", "confirm-test", false, false, false);
69-
}
70-
71-
public void testPersistentSimple()
66+
public void testPersistentMandatoryImmediateCombinations()
7267
throws IOException, InterruptedException
7368
{
74-
confirmTest("", "confirm-test", true, false, false);
69+
boolean b[] = { false, true };
70+
for (boolean persistent : b) {
71+
for (boolean mandatory : b) {
72+
for (boolean immediate : b) {
73+
confirmTest("", "confirm-test",
74+
persistent, mandatory, immediate);
75+
}
76+
}
77+
}
7578
}
7679

7780
public void testNonDurable()
@@ -80,28 +83,18 @@ public void testNonDurable()
8083
confirmTest("", "confirm-test-nondurable", true, false, false);
8184
}
8285

83-
public void testPersistentImmediate()
84-
throws IOException, InterruptedException
85-
{
86-
confirmTest("", "confirm-test", true, false, true);
87-
}
88-
89-
public void testPersistentImmediateNoConsumer()
90-
throws IOException, InterruptedException
91-
{
92-
confirmTest("", "confirm-test-noconsumer", true, false, true);
93-
}
94-
95-
public void testPersistentMandatory()
86+
public void testImmediateNoConsumer()
9687
throws IOException, InterruptedException
9788
{
98-
confirmTest("", "confirm-test", true, true, false);
89+
confirmTest("", "confirm-test-noconsumer", false, false, true);
90+
confirmTest("", "confirm-test-noconsumer", true, false, true);
9991
}
10092

101-
public void testPersistentMandatoryReturn()
93+
public void testMandatoryNoRoute()
10294
throws IOException, InterruptedException
10395
{
104-
confirmTest("", "confirm-test-doesnotexist", true, true, false);
96+
confirmTest("", "confirm-test-doesnotexist", false, true, false);
97+
confirmTest("", "confirm-test-doesnotexist", true, true, false);
10598
}
10699

107100
public void testMultipleQueues()

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -385,7 +385,7 @@ private void assertDeathReason(List<Object> death, int num,
385385
assertEquals(exchange, deathHeader.get("exchange").toString());
386386

387387
List<String> deathRKs = new ArrayList<String>();
388-
for (Object rk : (ArrayList)deathHeader.get("routing-keys")) {
388+
for (Object rk : (ArrayList<?>)deathHeader.get("routing-keys")) {
389389
deathRKs.add(rk.toString());
390390
}
391391
Collections.sort(deathRKs);

0 commit comments

Comments
 (0)