returning return value of remove (message may have been removed already).
This commit is contained in:
@@ -100,7 +100,7 @@ public class RetrievalBlockingMessageStore extends SimpleMessageStore implements
|
||||
if (holder != null) {
|
||||
message = holder.getMessage();
|
||||
if (message != null && shouldRemove) {
|
||||
super.remove(key);
|
||||
return super.remove(key);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user