mq-bridge 0.3.6

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

//  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

mod endpoint;
pub mod memory_transport;
pub mod transport;

#[cfg(any(unix, windows))]
mod framed;
#[cfg(unix)]
pub mod ipc_unix;
#[cfg(windows)]
pub mod ipc_windows;

// Re-export the main endpoint types for backward compatibility
pub use endpoint::{
    get_or_create_channel, get_or_create_response_channel, MemoryChannel, MemoryConsumer,
    MemoryPublisher, MemoryQueueConsumer, MemoryResponseChannel, MemorySubscriber,
};