Stack Overflow
Stack Overflow

Questions tagged [chronicle-wire]

17 questions
2
votes
1 answer

Chronicle Queue: How to read excepts/documents with different WireKey?

Assume a chronicle queue, and a producer that writes 2 types of messages into the queue. Each type of message is written with a different "WireKey". // Writes: {key1: TestMessage} appender.writeDocument(w -> w.write("key1").text("TestMessage")); //…
ccnlui
  • 91
  • 5
1
vote
1 answer

Spring Boot and dynamic compilation in Chronicle Wire

Referring to the title above. To get Chronicle wire dynamic compilation to work with springboot, it requires you to unpack chronicle jars unto a temp directory so that the platform compiler can see classes from the fat JAR. Referring to the docs…
David Teh
  • 61
  • 5
1
vote
1 answer

How to effectively parse and store data to Chronicle Map

I'm trying to figure out shortest and effective path to parse values from json and store some of them into chronicle map. My current solution: String data = ...; ChronicleMap map = ...; JSONWire wire = new…
Evgeny Kapaev
  • 13
  • 2
1
vote
1 answer

Handling chronicle-queue warning : "reading control code as text"

I am reading a provided Chronicle Queue file via a tailer. Upon creating the tailer I get the warning message: "reading control code as text" There seems to be a certain section(s) of the file that causes this warning to be logged. The other records…
public.persona
  • 23
  • 6
1
vote
2 answers

Can I parse the chronicle queue file

Write data to Chronicle queue. This creates/updates the chronicle queue file and is written in 20220525F.cq4 Query :- Is it possible to parse the file 20220525F.cq4 , what is the data format used to write the file ?
Abhishek Sharma
  • 11
  • 2
1
vote
1 answer

Chronicle-Queue: Why does busy-waiting tailer generate garbage when spinning (nothing to be read)?

I have a busy-waiting loop in which a tailer is constantly trying to read from a queue: final Bytes bbb = Bytes.elasticByteBuffer(MAX_SIZE, MAX_SIZE); // Busy wait loop. while (true) { tailer.readDocument(wire -> { …
ccnlui
  • 91
  • 5
1
vote
1 answer

Chronicle Queue: Is recordHistory() not available anymore?

I'd like to benchmark the queue performance using the method demonstrated in github README. However, when I tried on the latest version (chronicle-queue: 5.23ea5, chronicle-wire: 2.23ea5), recordHistory(bool recordHistory) doesn't seem to be…
ccnlui
  • 91
  • 5
1
vote
1 answer

Chronicle Bytes Release Method Deprecated

I recently moved to JDK 17 from JDK 11 which triggered an update to the Chronicle Wire library. We used to use version 2.17.50 with JDK 11 and now we have moved to chronicle-wire version 2.22.17 and chronicle-bytes version 2.22.21. Following code…
ATO
  • 574
  • 4
  • 14
1
vote
1 answer

Chronicle Queue JSON

I'm currently trying to marshal a certain POJO as JSON and write it to an output queue. This is the run down of what I'm trying to do: object OrderExecutor { const val OUT_PATH = "${PATH}/order-executor/out" @JvmStatic fun main(args:…
David Teh
  • 61
  • 5
1
vote
1 answer

Does ChronicleWire support optional fields in entities?

I am experimenting with ChronicleWire. As described in features optional fields are supported out of the box. I just created a simple self-describing entity with one optional (nullable) field: public class Foo extends SelfDescribingMarshallable { …
rvit34
  • 1,967
  • 3
  • 17
  • 33
1
vote
1 answer

How to serialize a list of SelfDescribingMarshallables to CSV

I need to serialize a list of SelfDescribingMarshallables of the same type as CSV output row by row using Chronicle Wire. But net.openhft.chronicle.wire.WireType#CSV produces a row for every object field, so it is not a CSV. Are there any code…
injecto
  • 829
  • 1
  • 10
  • 23
1
vote
1 answer

Chronicle write introducing 1-2 sec latency at file roll over time

We have a single threaded java process that is writing messages into chronicle queue. The queue (SingleChronicleQueue) is configured with RollCycle HOURLY. At the hourly mark, when the file roll happens, chronicle write takes more than a second…
rj_89
  • 11
  • 5
1
vote
1 answer

How to serialize a simple object for Chronicle Queue using Chronicle Wire

I currently put my objects in the Chronicle Queue as follows ExcerptAppender appender = SingleChronicleQueueBuilder .binary("/path_to_chronicle/") .build() .acquireAppender(); // Write synchronized…
user3607022
  • 480
  • 3
  • 16
0
votes
0 answers

How to parse complex nested json using chronical-wired in tree-like manner?

I have a valid json: { "arg": { "channel": "a", "sub": "b" }, "action": "update", "data": [{ "a": [ [ "0.35543", "199.194504", "0", …
Dmitry Zagorulkin
  • 8,370
  • 4
  • 37
  • 60
0
votes
2 answers

Can ChronicleQueue tailers for two different queues be interleaved?

I have two separate ChronicleQueues that were created by independent threads that monitor web socket streams in a Java application. When I read each queue independently in a separate single-thread program, I can traverse each entire queue as…
Jack Copper
  • 33
  • 1
  • 9
1
2