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 2019/05/01 01:04:11 UTC
[qpid-broker-j] branch master updated: QPID-8303: [Broker-J][JDBC
Message Store] Fix test
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
The following commit(s) were added to refs/heads/master by this push:
new afd1dc8 QPID-8303: [Broker-J][JDBC Message Store] Fix test
afd1dc8 is described below
commit afd1dc83251254c82340d89b389b69bc17edd373
Author: Alex Rudyy <or...@apache.org>
AuthorDate: Wed May 1 01:58:12 2019 +0100
QPID-8303: [Broker-J][JDBC Message Store] Fix test
---
.../org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java b/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java
index d19c034..c289b5e 100644
--- a/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java
+++ b/broker-plugins/jdbc-store/src/test/java/org/apache/qpid/server/store/jdbc/JDBCMessageStoreTest.java
@@ -58,6 +58,7 @@ import org.apache.qpid.server.store.MessageDurability;
import org.apache.qpid.server.store.MessageEnqueueRecord;
import org.apache.qpid.server.store.MessageStore;
import org.apache.qpid.server.store.MessageStoreTestCase;
+import org.apache.qpid.server.store.StoredMessage;
import org.apache.qpid.server.store.Transaction;
import org.apache.qpid.server.store.TransactionLogResource;
import org.apache.qpid.server.virtualhost.jdbc.JDBCVirtualHost;
@@ -213,9 +214,9 @@ public class JDBCMessageStoreTest extends MessageStoreTestCase
store.removeMessages(records.stream().map(MessageEnqueueRecord::getMessageNumber).collect(Collectors.toList()));
- final List<MessageEnqueueRecord> stored = new ArrayList<>();
- store.newMessageStoreReader().visitMessageInstances(resource, (r) -> {
- stored.add(r);
+ final List<StoredMessage> stored = new ArrayList<>();
+ store.newMessageStoreReader().visitMessages(m-> {
+ stored.add(m);
return true;
});
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org