Quickstart

The current distribution is a source checkout. Published binaries and production configuration are not ready yet.

Prerequisites

• A current Rust toolchain
• Git

Run the broker

git clone https://github.com/Axmouth/fibril.git
cd fibril
cargo run --release --bin fibril-server

The development server currently:

• listens for broker TCP traffic on 0.0.0.0:9876
• serves the early admin interface on 0.0.0.0:8081
• stores durable state under server_data/
• uses development authentication defaults in the server binary

Do not expose this development server directly to the public internet.

Rust client shape

The Rust client lives in crates/client. It supports publishers and manual-ack subscriptions:

let client = ClientOptions::new()
    .auth("fibril", "fibril")
    .connect("127.0.0.1:9876")
    .await?;

let publisher = client.publisher("email.send");
publisher.publish("hello").await?;

let mut sub = client
    .subscribe("email.send")
    .prefetch(32)
    .sub_manual_ack()
    .await?;

while let Some(msg) = sub.recv().await {
    process(msg.content()?).await?;
    msg.complete().await?;
}

The API is evolving. Treat examples as a guide to the current source tree rather than a stable package contract.