Skip to content

Commit

Permalink
AMQP-849: Fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
garyrussell committed Dec 13, 2018
1 parent 8051eda commit 963b3b7
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ public void channelReleasedOnTimeout() throws Exception {
Message replyMessage = new Message("foo".getBytes(), new MessageProperties());
assertThatThrownBy(() -> template.onMessage(replyMessage))
.isInstanceOf(AmqpRejectAndDontRequeueException.class)
.hasMessage("No correlation header");
.hasMessage("No correlation header in reply");
replyMessage.getMessageProperties().setCorrelationId("foo");
assertThatThrownBy(() -> template.onMessage(replyMessage))
.isInstanceOf(AmqpRejectAndDontRequeueException.class)
Expand Down

0 comments on commit 963b3b7

Please sign in to comment.