Skip to content

Commit e8d82b0

Browse files
committed
fix timeout in DittoClientPoliciesTest
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
1 parent 630b17e commit e8d82b0

File tree

1 file changed

+4
-8
lines changed

1 file changed

+4
-8
lines changed

java/src/test/java/org/eclipse/ditto/client/DittoClientPoliciesTest.java

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -57,14 +57,10 @@ public final class DittoClientPoliciesTest extends AbstractDittoClientTest {
5757
public void verifyClientDefaultsToSchemaVersion2ForPolicyCommands() {
5858
messaging = new MockMessagingProvider(JsonSchemaVersion.V_1);
5959
final DittoClient client = DittoClients.newInstance(messaging);
60-
try {
61-
assertEventualCompletion(client.policies().retrieve(POLICY_ID));
62-
final RetrievePolicy command = expectMsgClass(RetrievePolicy.class);
63-
reply(RetrievePolicyResponse.of(POLICY_ID, POLICY, command.getDittoHeaders()));
64-
assertThat(command).hasSchemaVersion(JsonSchemaVersion.V_2);
65-
} finally {
66-
client.destroy();
67-
}
60+
assertEventualCompletion(client.policies().retrieve(POLICY_ID).thenRun(client::destroy));
61+
final RetrievePolicy command = expectMsgClass(RetrievePolicy.class);
62+
reply(RetrievePolicyResponse.of(POLICY_ID, POLICY, command.getDittoHeaders()));
63+
assertThat(command).hasSchemaVersion(JsonSchemaVersion.V_2);
6864
}
6965

7066
@Test

0 commit comments

Comments
 (0)