Chronicle-Queue
Chronicle-Queue copied to clipboard
OpenHFT
Micro second messaging that stores everything to disk
Hi , We have a 2 process model. A Inbound process writes messages to chronicle que. The Outbound process is reading messages from chronicle que. Both inbound and outbound are...
``` java.lang.AssertionError at net.openhft.chronicle.queue.impl.single.SCQIndexing.sequenceForPosition(SCQIndexing.java:519) at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueStore.sequenceForPosition(SingleChronicleQueueStore.java:309) at net.openhft.chronicle.queue.impl.single.StoreTailer.beyondStartOfCycleBackward(StoreTailer.java:376) at net.openhft.chronicle.queue.impl.single.StoreTailer.beyondStartOfCycle(StoreTailer.java:339) at net.openhft.chronicle.queue.impl.single.StoreTailer.next0(StoreTailer.java:304) at net.openhft.chronicle.queue.impl.single.StoreTailer.readingDocument0(StoreTailer.java:219) at net.openhft.chronicle.queue.impl.single.StoreTailer.readingDocument(StoreTailer.java:194) at net.openhft.chronicle.queue.impl.single.StoreTailer.readingDocument(StoreTailer.java:138) at software.chronicle.fix.staticcode.msgseq.QueueMsgSequenceHandler.refresh(QueueMsgSequenceHandler.java:57) ``` Possibly related to #1059
Bumps hsqldb from 2.6.1 to 2.7.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [exec-maven-plugin](https://github.com/mojohaus/exec-maven-plugin) from 3.0.0 to 3.1.0. Release notes Sourced from exec-maven-plugin's releases. 3.1.0 🚀 New features and improvements Require Maven 3.2.5 (#319) @slawekjaranowski Support stream inheritance for the forked process,...
Within chronicle queue code and tests there are cases where time is acquired via timeProviders or System.currentTime() methods. Queue and its internal components shall all use timeProvider which depending on...
There are a few obvious gaps here - of particular concern is gaps in readingDocument0 and associated methods
The [IncompleteMessageTest](https://github.com/OpenHFT/Chronicle-Queue/blob/ea/src/test/java/net/openhft/chronicle/queue/IncompleteMessageTest.java) tests the behaviour of Queue when a write is started but not completed. A second write is then attempted, which - correctly - forces the lock and succeeds....