|
51 | 51 | import java.time.ZoneOffset; |
52 | 52 | import java.time.temporal.ChronoUnit; |
53 | 53 | import java.util.ArrayList; |
| 54 | +import java.util.Collection; |
54 | 55 | import java.util.Date; |
55 | 56 | import java.util.TimeZone; |
56 | 57 | import java.util.concurrent.TimeUnit; |
|
62 | 63 | import static org.junit.Assert.assertNull; |
63 | 64 | import static org.junit.Assert.assertTrue; |
64 | 65 | import static org.junit.Assert.fail; |
| 66 | +import static org.mockito.ArgumentMatchers.any; |
65 | 67 | import static org.mockito.ArgumentMatchers.anyString; |
| 68 | +import org.mockito.Mockito; |
66 | 69 | import static org.mockito.Mockito.atLeastOnce; |
67 | 70 | import static org.mockito.Mockito.mock; |
68 | 71 | import static org.mockito.Mockito.times; |
@@ -161,6 +164,19 @@ public void testNondisposableFileResources() throws Exception { |
161 | 164 | } |
162 | 165 | } |
163 | 166 |
|
| 167 | + private static class MyUnitTestApplication extends UnitTestApplication { |
| 168 | + |
| 169 | + /** |
| 170 | + * Just uses no logging on fromApp since testLargeQueue() sends quite |
| 171 | + * some messages. |
| 172 | + */ |
| 173 | + @Override |
| 174 | + public void fromApp(Message message, SessionID sessionId) throws FieldNotFound, |
| 175 | + IncorrectDataFormat, IncorrectTagValue, UnsupportedMessageType { |
| 176 | + fromAppMessages.add(message); |
| 177 | + } |
| 178 | + } |
| 179 | + |
164 | 180 | private interface CloseableMessageStore extends MessageStore, Closeable { |
165 | 181 | } |
166 | 182 |
|
@@ -2353,9 +2369,9 @@ private void testLargeQueue(int N) throws Exception { |
2353 | 2369 | final SessionID sessionID = new SessionID(FixVersions.BEGINSTRING_FIX44, "SENDER", "TARGET"); |
2354 | 2370 |
|
2355 | 2371 | boolean isInitiator = true, resetOnLogon = false, validateSequenceNumbers = true; |
2356 | | - final UnitTestApplication unitTestApplication = new UnitTestApplication(); |
| 2372 | + final UnitTestApplication unitTestApplication = new MyUnitTestApplication(); |
2357 | 2373 |
|
2358 | | - Session session = new Session(new UnitTestApplication(), |
| 2374 | + Session session = new Session(unitTestApplication, |
2359 | 2375 | new MemoryStoreFactory(), new InMemoryMessageQueueFactory(), sessionID, null, null, null, null, |
2360 | 2376 | new DefaultMessageFactory(), isInitiator ? 30 : 0, false, 30, UtcTimestampPrecision.MILLIS, resetOnLogon, |
2361 | 2377 | false, false, false, false, false, true, false, 1.5, null, validateSequenceNumbers, |
|
0 commit comments