Skip to content

Commit aa1e080

Browse files
committed
Wait for DBMS to actually shutdown in InMemoryGraphTrackerLifecycleAdapterTest
1 parent 19ef29d commit aa1e080

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

core/src/main/java/org/neo4j/gds/core/loading/InMemoryGraphTrackerLifecycleAdapter.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,11 +29,11 @@
2929
import java.util.HashMap;
3030
import java.util.Map;
3131

32-
class InMemoryGraphTrackerLifecycleAdapter extends LifecycleAdapter implements DatabaseEventListener {
32+
public class InMemoryGraphTrackerLifecycleAdapter extends LifecycleAdapter implements DatabaseEventListener {
3333
private final DatabaseManagementService dbms;
3434
private final Map<String, DatabaseId> databaseIdMapping;
3535

36-
InMemoryGraphTrackerLifecycleAdapter(DatabaseManagementService dbms) {
36+
public InMemoryGraphTrackerLifecycleAdapter(DatabaseManagementService dbms) {
3737
this.dbms = dbms;
3838
this.databaseIdMapping = new HashMap<>();
3939
}
@@ -58,14 +58,13 @@ public void databasePanic(DatabaseEventContext eventContext) {
5858
databaseIsShuttingDown(eventContext.getDatabaseName());
5959
}
6060

61-
// The @override is missing for compatibility reasons
62-
public void databaseCreate(DatabaseEventContext eventContext) {
61+
@Override public void databaseCreate(DatabaseEventContext eventContext) {
6362
var databaseName = eventContext.getDatabaseName();
6463
var db = dbms.database(databaseName);
6564
databaseIdMapping.put(databaseName, DatabaseId.of(db.databaseName()));
6665
}
6766

68-
// The @override is missing for compatibility reasons
67+
@Override
6968
public void databaseDrop(DatabaseEventContext eventContext) {
7069
databaseIdMapping.remove(eventContext.getDatabaseName());
7170
}

0 commit comments

Comments
 (0)