File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/test/java/com/rabbitmq/client/amqp/impl Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -125,8 +125,9 @@ void requeuedMessageWithAnnotationShouldContainAnnotationsOnRedelivery() {
125
125
Message message = messages .poll ();
126
126
assertThat (message ).doesNotHaveAnnotation ("x-delivery-count" );
127
127
message = messages .poll ();
128
- assertThat (message ).hasAnnotation ("x-delivery-count" , 1L );
129
- // .hasAnnotation(ANNOTATION_KEY, ANNOTATION_VALUE);
128
+ assertThat (message )
129
+ .hasAnnotation ("x-delivery-count" , 1L )
130
+ .hasAnnotation (ANNOTATION_KEY , ANNOTATION_VALUE );
130
131
waitAtMost (() -> management .queueInfo (q ).messageCount () == 0 );
131
132
}
132
133
@@ -187,8 +188,7 @@ void discardedMessageShouldBeDeadLeadLetteredWhenConfigured() {
187
188
publisher .publish (publisher .message ().messageId (messageID ), ctx -> {});
188
189
assertThat (deadLetteredSync ).completes ();
189
190
Message message = deadLetteredMessage .get ();
190
- assertThat (message ).hasId (messageID );
191
- // .hasAnnotation(ANNOTATION_KEY, ANNOTATION_VALUE);
191
+ assertThat (message ).hasId (messageID ).hasAnnotation (ANNOTATION_KEY , ANNOTATION_VALUE );
192
192
waitAtMost (() -> management .queueInfo (q ).messageCount () == 0 );
193
193
waitAtMost (() -> management .queueInfo (dlq ).messageCount () == 0 );
194
194
}
You can’t perform that action at this time.
0 commit comments