diff --git a/package.json b/package.json index 14515f0..a0b0ae9 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "eventstore-node", - "version": "0.0.18", + "version": "0.0.19", "description": "A port of the EventStore .Net ClientAPI to Node.js", "main": "index.js", "types": "index.d.ts", diff --git a/src/core/operationsManager.js b/src/core/operationsManager.js index 6e2e12d..0c06402 100644 --- a/src/core/operationsManager.js +++ b/src/core/operationsManager.js @@ -121,7 +121,7 @@ OperationsManager.prototype.scheduleOperationRetry = function(operation) { }; OperationsManager.prototype.removeOperation = function(operation) { - this._activeOperations.remove(operation.connectionId); + this._activeOperations.remove(operation.correlationId); this._logDebug("RemoveOperation SUCCEEDED for %s.", operation); this._totalOperationCount = this._activeOperations.length + this._waitingOperations.length; return true;