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() {
125125 Message message = messages .poll ();
126126 assertThat (message ).doesNotHaveAnnotation ("x-delivery-count" );
127127 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 );
130131 waitAtMost (() -> management .queueInfo (q ).messageCount () == 0 );
131132 }
132133
@@ -187,8 +188,7 @@ void discardedMessageShouldBeDeadLeadLetteredWhenConfigured() {
187188 publisher .publish (publisher .message ().messageId (messageID ), ctx -> {});
188189 assertThat (deadLetteredSync ).completes ();
189190 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 );
192192 waitAtMost (() -> management .queueInfo (q ).messageCount () == 0 );
193193 waitAtMost (() -> management .queueInfo (dlq ).messageCount () == 0 );
194194 }
You can’t perform that action at this time.
0 commit comments