QPID-8303: [Broker-J][JDBC Message Store] Fix test
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.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 @@
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;
});
