diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java index 7ff067188e..680ecde9c0 100644 --- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java +++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java @@ -43,9 +43,10 @@ public interface Index{ * remove the index key * * @param key + * @return StoreEntry removed * @throws IOException */ - public void remove(Object key) throws IOException; + public StoreEntry remove(Object key) throws IOException; /** * store the key, item diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java index df465e9911..3649ed78db 100644 --- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java +++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java @@ -49,8 +49,8 @@ public class VMIndex implements Index{ * @param key * @see org.apache.activemq.kaha.impl.index.Index#removeKey(java.lang.Object) */ - public void remove(Object key){ - map.remove(key); + public StoreEntry remove(Object key){ + return map.remove(key); } /**