Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
cypherean committed Mar 20, 2023
1 parent 9a76a2b commit fe2b19e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 25 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@

package io.mantisrx.server.core;

import static org.junit.jupiter.api.Assertions.assertAll;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertTrue;

Expand All @@ -31,10 +30,7 @@ public void testEquals() {
WorkerHost w2 = new WorkerHost("localhost", 1, ImmutableList.of(7001, 7002), MantisJobState.Accepted, 2, 7003, 7004);
WorkerHost w3 = new WorkerHost("localhost", 1, ImmutableList.of(7001, 7002), MantisJobState.Accepted, 2, 7003, 7005);

// required?
assertAll(
() -> assertTrue(w1.equals(w2)),
() -> assertFalse(w1.equals(w3))
);
assertTrue(w1.equals(w2));
assertFalse(w1.equals(w3));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -59,23 +59,6 @@ public class MantisJobDiscoveryTest {
private MrePublishConfiguration config;
private MantisJobDiscovery jobDiscovery;

// public class WireMockExtension implements AfterEachCallback, BeforeEachCallback {
// static WireMockServer mantisAPI = new WireMockServer();
// @Override
// public void beforeEach(ExtensionContext context) throws Exception {
// mantisAPI.start();
// }
//
// @Override
// public void afterEach(ExtensionContext context) throws Exception {
// mantisAPI.shutdown();
// }
//
// public static WireMockServer getMantisAPI() {
// return mantisAPI;
// }
// }

public MantisJobDiscoveryTest() {
streamJobClusterMap.put(StreamType.DEFAULT_EVENT_STREAM, "RequestEventSubTrackerTestJobCluster");
streamJobClusterMap.put(StreamType.LOG_EVENT_STREAM, "LogEventSubTrackerTestJobCluster");
Expand Down Expand Up @@ -110,10 +93,8 @@ public void teardown() {
mantisApi.shutdown();
}

// @ExtendWith(WireMockExtension.class)
@Test
public void testJobDiscoveryFetch() throws IOException {
// WireMockServer mantisAPI = WireMockExtension.getMantisAPI();
String jobCluster = "MantisJobDiscoveryTestJobCluster";
String jobId = jobCluster + "-1";

Expand Down

0 comments on commit fe2b19e

Please sign in to comment.