We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c45ad73 commit d859205Copy full SHA for d859205
src/test/java/com/rabbitmq/client/test/functional/Metrics.java
@@ -154,6 +154,7 @@ protected void releaseResources() throws IOException {
154
channel.basicPublish(
155
"any-exchange",
156
"any-routing-key",
157
+ /* basic.return will be sent back only if the message is mandatory */ true,
158
MessageProperties.MINIMAL_BASIC,
159
"any-message".getBytes()
160
);
@@ -162,7 +163,6 @@ protected void releaseResources() throws IOException {
162
163
() -> metrics.getPublishUnroutedMessages().getCount(),
164
equalTo(1L)
165
- assertThat(metrics.getPublishUnroutedMessages().getCount(), is(1L));
166
} finally {
167
safeClose(connection);
168
}
0 commit comments