diff --git a/packages/transaction-pool-worker/source/handlers/remove-transaction.ts b/packages/transaction-pool-worker/source/handlers/remove-transaction.ts index 1497a1bc9..2a1ab5d77 100644 --- a/packages/transaction-pool-worker/source/handlers/remove-transaction.ts +++ b/packages/transaction-pool-worker/source/handlers/remove-transaction.ts @@ -6,7 +6,11 @@ export class RemoveTransactionHandler { @inject(Identifiers.TransactionPool.Mempool) private readonly mempool!: Contracts.TransactionPool.Mempool; + @inject(Identifiers.TransactionPool.Storage) + private readonly storage!: Contracts.TransactionPool.Storage; + public async handle(address: string, id: string): Promise { await this.mempool.removeTransaction(address, id); + this.storage.removeTransaction(id); } }