mq-bridge 0.3.5

An asynchronous message bridging library connecting Kafka, MQTT, AMQP, NATS, MongoDB, HTTP, and more.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

//  mq-bridge
//  © Copyright 2025, by Marco Mengelkoch
//  Licensed under MIT License, see License file for more details
//  git clone https://github.com/marcomq/mq-bridge
pub mod canonical_message;
#[cfg(any(
    feature = "mongodb",
    feature = "sqlx",
    feature = "clickhouse",
    feature = "object-store"
))]
pub mod checkpoint;
pub mod command_handler;
pub mod connection_registry;
pub mod endpoints;
pub mod errors;
pub mod event_handler;
pub mod event_store;
pub mod extensions;
pub mod middleware;
pub mod models;
pub mod outcomes;
pub mod publisher;
pub mod response;
pub mod route;
#[cfg(feature = "test-utils")]
pub mod test_utils;
pub mod traits;
pub mod type_handler;

pub use anyhow;
pub use canonical_message::{CanonicalMessage, MessageContext};
pub use errors::HandlerError;
pub use models::Route;
pub use outcomes::{Handled, Received, ReceivedBatch, Sent, SentBatch};
pub use publisher::Publisher;

pub use endpoints::memory::get_or_create_channel;
pub use publisher::{get_publisher, list_publishers, register_publisher, unregister_publisher};
pub use route::{get_route, list_routes, register_endpoint, stop_route};

// Re-export the underlying driver crate for each feature-gated endpoint, so
// downstream code can depend on the exact same version mq-bridge builds against
// (and share types with it) without adding — and keeping in sync — its own
// dependency entry. Each is gated on the feature that pulls the crate in.
#[cfg(feature = "nats")]
pub use async_nats;
#[cfg(feature = "amqp")]
pub use lapin;
#[cfg(feature = "mongodb")]
pub use mongodb;
#[cfg(feature = "kafka")]
pub use rdkafka;
#[cfg(feature = "redis-streams")]
pub use redis;
#[cfg(feature = "clickhouse")]
pub use reqwest;
#[cfg(feature = "mqtt")]
pub use rumqttc;
#[cfg(feature = "websocket")]
pub use tokio_websockets;
#[cfg(feature = "zeromq")]
pub use zeromq;
#[cfg(feature = "aws")]
pub use {aws_config, aws_sdk_sns, aws_sdk_sqs};
#[cfg(feature = "grpc")]
pub use {prost, tonic};
// `sqlx` is also enabled transitively by `postgres-cdc`; the integration tests
// use this re-export instead of a duplicate dev-dependency.
#[cfg(any(feature = "ibm-mq", feature = "ibm-mq-static"))]
pub use mqi;
#[cfg(feature = "postgres-cdc")]
pub use pgwire_replication;
#[cfg(feature = "sqlx")]
pub use sqlx;

pub mod consumer {
    pub use crate::middleware::apply_middlewares_to_consumer as apply_middlewares;
}

/// The application name, derived from the package name in Cargo.toml.
pub const APP_NAME: &str = env!("CARGO_PKG_NAME");