Skip to content

Commit a3e2e5c

Browse files
author
Emile Joubert
committed
CcRoute test updates
1 parent 784c576 commit a3e2e5c

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,8 +87,9 @@ public void testCcSingleton() throws IOException {
8787

8888
public void testCcList() throws IOException {
8989
ccList.add("queue2");
90+
ccList.add("queue3");
9091
headerPublish("", "queue1", ccList, null);
91-
expect(new String []{"queue1", "queue2"});
92+
expect(new String []{"queue1", "queue2", "queue3"});
9293
}
9394

9495
public void testCcIgnoreEmptyAndInvalidRoutes() throws IOException {
@@ -152,7 +153,9 @@ private void expect(String[] expectedQueues) throws IOException {
152153
if (expectedList.contains(q)) {
153154
assertNotNull(getResponse);
154155
assertEquals(0, getResponse.getMessageCount());
155-
assertFalse(getResponse.getProps().getHeaders().containsKey("BCC"));
156+
Map headers = getResponse.getProps().getHeaders();
157+
if (headers != null)
158+
assertFalse(headers.containsKey("BCC"));
156159
} else {
157160
assertNull(getResponse);
158161
}

0 commit comments

Comments
 (0)