You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2015/07/29 03:19:04 UTC
[2/2] karaf-cellar git commit: [KARAF-3873] Fix remove of pending
commands in the TimeoutTask
[KARAF-3873] Fix remove of pending commands in the TimeoutTask
Project: http://git-wip-us.apache.org/repos/asf/karaf-cellar/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf-cellar/commit/71a5f9eb
Tree: http://git-wip-us.apache.org/repos/asf/karaf-cellar/tree/71a5f9eb
Diff: http://git-wip-us.apache.org/repos/asf/karaf-cellar/diff/71a5f9eb
Branch: refs/heads/master
Commit: 71a5f9eb4034716ac73ae53d5e6beb59671ca82b
Parents: 95cc34d
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Wed Jul 29 03:18:39 2015 +0200
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Wed Jul 29 03:18:39 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/karaf/cellar/core/command/TimeoutTask.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf-cellar/blob/71a5f9eb/core/src/main/java/org/apache/karaf/cellar/core/command/TimeoutTask.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/karaf/cellar/core/command/TimeoutTask.java b/core/src/main/java/org/apache/karaf/cellar/core/command/TimeoutTask.java
index 6546339..01f37dc 100644
--- a/core/src/main/java/org/apache/karaf/cellar/core/command/TimeoutTask.java
+++ b/core/src/main/java/org/apache/karaf/cellar/core/command/TimeoutTask.java
@@ -32,9 +32,9 @@ public class TimeoutTask implements Runnable {
@Override
public void run() {
// check if command is still pending
- Boolean pending = store.getPending().containsKey(command);
+ Boolean pending = store.getPending().containsKey(command.getId());
if (pending) {
- store.getPending().remove(command);
+ store.getPending().remove(command.getId());
}
}