You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/06/09 16:08:00 UTC
qpid-broker-j git commit: QPID-7811: Improve test to verify that last
stored orphaned message is removed
Repository: qpid-broker-j
Updated Branches:
refs/heads/master cf1af38c6 -> f03a3c460
QPID-7811: Improve test to verify that last stored orphaned message is removed
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/f03a3c46
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/f03a3c46
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/f03a3c46
Branch: refs/heads/master
Commit: f03a3c460b1782688627588fcb646df6a9a537e6
Parents: cf1af38
Author: Alex Rudyy <or...@apache.org>
Authored: Fri Jun 9 17:07:11 2017 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Fri Jun 9 17:07:11 2017 +0100
----------------------------------------------------------------------
.../virtualhost/AsynchronousMessageStoreRecovererTest.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/f03a3c46/broker-core/src/test/java/org/apache/qpid/server/virtualhost/AsynchronousMessageStoreRecovererTest.java
----------------------------------------------------------------------
diff --git a/broker-core/src/test/java/org/apache/qpid/server/virtualhost/AsynchronousMessageStoreRecovererTest.java b/broker-core/src/test/java/org/apache/qpid/server/virtualhost/AsynchronousMessageStoreRecovererTest.java
index f8a0589..49d6a80 100644
--- a/broker-core/src/test/java/org/apache/qpid/server/virtualhost/AsynchronousMessageStoreRecovererTest.java
+++ b/broker-core/src/test/java/org/apache/qpid/server/virtualhost/AsynchronousMessageStoreRecovererTest.java
@@ -118,6 +118,9 @@ public class AsynchronousMessageStoreRecovererTest extends QpidTestCase
final List<StoredMessage<?>> testMessages = new ArrayList<>();
StoredMessage<?> storedMessage = createTestMessage(1L);
testMessages.add(storedMessage);
+ StoredMessage<?> orphanedMessage = createTestMessage(2L);
+ testMessages.add(orphanedMessage);
+
StoredMessage newMessage = createTestMessage(4L);
testMessages.add(newMessage);
@@ -133,6 +136,7 @@ public class AsynchronousMessageStoreRecovererTest extends QpidTestCase
ListenableFuture<Void> result = recoverer.recover(_virtualHost);
assertNull(result.get());
+ verify(orphanedMessage, times(1)).remove();
verify(newMessage, times(0)).remove();
verify(queue).recover(argThat(new ArgumentMatcher<ServerMessage>()
{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org