Mirror/MarginaliaSearch
1
0
Fork 0
mirror of https://github.com/MarginaliaSearch/MarginaliaSearch.git synced 2025-02-24 13:19:02 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(minor) Fix test

Browse Source
This commit is contained in:
Viktor Lofgren 2023-07-12 18:15:50 +02:00
parent 8c16a2aede
commit 89e4343fdb
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
code/common/message-queue/src/test/java/nu/marginalia/mq/persistence/MqPersistenceTest.java
View File

@ -161,7 +161,7 @@ public class MqPersistenceTest {
long id = persistence.sendNewMessage(recipientId, null,"function", "payload", Duration.ofSeconds(30)); long id = persistence.sendNewMessage(recipientId, null,"function", "payload", Duration.ofSeconds(30));
var messagesPollFirstTime = persistence.pollInbox(recipientId, instanceId , tick); var messagesPollFirstTime = persistence.pollInbox(recipientId, instanceId , tick, 10);
/** CHECK POLL RESULT */ /** CHECK POLL RESULT */
assertEquals(1, messagesPollFirstTime.size()); assertEquals(1, messagesPollFirstTime.size());
@ -184,7 +184,7 @@ public class MqPersistenceTest {
assertEquals(tick, message.ownerTick()); assertEquals(tick, message.ownerTick());
/** VERIFY SECOND POLL IS EMPTY */ /** VERIFY SECOND POLL IS EMPTY */
var messagePollSecondTime = persistence.pollInbox(recipientId, instanceId , 1); var messagePollSecondTime = persistence.pollInbox(recipientId, instanceId , 1, 10);
assertEquals(0, messagePollSecondTime.size()); assertEquals(0, messagePollSecondTime.size());
} }
} }