Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
maamalama committed Sep 18, 2024
1 parent 66927dd commit 8e641c3
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions valhalla/jawn/src/workers/consumerManager.ts
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
import { Worker } from "worker_threads";
import { ShutdownManager } from "../managers/shutdown/ShutdownService";
import { ShutdownService } from "../managers/shutdown/ShutdownService";

export class ConsumerManager {
private static instance: ConsumerManager;
private workers: Worker[] = [];

private constructor() {
// Register shutdown handler
ShutdownManager.getInstance().addHandler(() => this.shutdown());
ShutdownService.getInstance().addHandler(() => this.shutdown());
}

public static getInstance(): ConsumerManager {
Expand Down

0 comments on commit 8e641c3

Please sign in to comment.