Serialization

flexiq uses a pluggable serializer for task arguments and results. The default is SmartSerializerJsonSerializerJsonSerializer, which uses MessagePack with a cloudpickle fallback for lambdas, closures, and complex objectsemits human-readable JSON bytesemits human-readable JSON bytes via Jackson.

from flexiq import Queue, JsonSerializer

# Use JSON for simpler, cross-language payloads
queue = Queue(serializer=JsonSerializer())

import { Queue, MsgpackSerializer } from "@byteveda/flexiq";

// Use msgpack for compact, binary payloads
new Queue({ dbPath: "flexiq.db", serializer: new MsgpackSerializer() });

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

// Use msgpack for compact, binary payloads
FlexiQ queue = FlexiQ.builder()
    .sqlite("flexiq.db")
    .serializer(new MsgpackSerializer())
    .open();

Built-in serializers

Custom serializers

Implement the Serializer interface with dumps(obj) / loads(data)serialize(value) / deserialize(bytes)serialize(value) / deserialize(bytes, type) methods.

What gets serialized

• Arguments: serialized and stored as a BLOB in payload
• Results: serialized and stored as a BLOB in result
• Periodic task args: serialized at registration time, stored as BLOBs in periodic_tasks.args