Serializers

import org.byteveda.flexiq.serialization.JsonSerializer;
import org.byteveda.flexiq.serialization.MsgpackSerializer;

FlexiQ flexiq = FlexiQ.builder()
        .sqlite("flexiq.db")
        .serializer(new MsgpackSerializer())
        .open();

Built-in serializers

Producers and workers must configure a compatible serializer — the Rust core treats payloads as opaque bytes.

import org.byteveda.flexiq.serialization.CborSerializer;

FlexiQ flexiq = FlexiQ.builder()
        .sqlite("flexiq.db")
        .serializer(new CborSerializer())
        .open();

Payload codecs

A PayloadCodec is a byte-to-byte transform (encode/decode) applied after serialization and reversed before deserialization — one implementation owns both directions so the inverse can't drift. Codecs follow the cross-SDK contract, so payloads survive producer/worker boundaries between SDKs.

A chain applies in order on encode and in reverse on decode — order GzipCodec before a signing/encryption codec so integrity is verified before decompressing:

FlexiQ flexiq = FlexiQ.builder()
        .sqlite("flexiq.db")
        .codec(new GzipCodec(), new HmacCodec(secret))   // global chain
        .codec("encrypted", new AesGcmCodec(key))        // named, per-task
        .open();

Task<Report> buildReport = Task.of("build_report", Report.class)
        .codecs("encrypted");                            // this task only

The global chain wraps the queue serializer (a CodecSerializer under the hood) and covers results too. Named codecs apply per task via Task.codecs or the @Compressed/@Encrypted annotations — the same names (and keys) must be registered on producers and workers.

The Serializer interface

public interface Serializer {
    byte[] serialize(Object value);
    <T> T deserialize(byte[] bytes, Class<T> type);
    default Object deserialize(byte[] bytes, Type type) { ... }
}

The Type overload supports generic payloads from a TypeReference; the default implementation handles plain Class types and rejects generic ones — override it in a generics-aware implementation (as JsonSerializer does).