This commit is contained in:
parent
a783a0e663
commit
92172479f6
1 changed files with 2 additions and 2 deletions
|
@ -17,7 +17,7 @@ class CassandraService {
|
||||||
private static logger: Echo = new Echo({ subDirectory: "cassandra" });
|
private static logger: Echo = new Echo({ subDirectory: "cassandra" });
|
||||||
private static loggerNoFile: Echo = new Echo({ disableFile: true });
|
private static loggerNoFile: Echo = new Echo({ disableFile: true });
|
||||||
|
|
||||||
private constructor() { }
|
private constructor() {}
|
||||||
|
|
||||||
public static getClient(): Client {
|
public static getClient(): Client {
|
||||||
if (!CassandraService.instance) {
|
if (!CassandraService.instance) {
|
||||||
|
@ -143,7 +143,7 @@ class CassandraService {
|
||||||
message: "Failed to connect to Cassandra:",
|
message: "Failed to connect to Cassandra:",
|
||||||
error,
|
error,
|
||||||
});
|
});
|
||||||
await client.shutdown().catch(() => { });
|
await client.shutdown().catch(() => {});
|
||||||
throw error;
|
throw error;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue