mq-bridge 0.2.10

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

syntax = "proto3";
package mqbridge;

service Bridge {
    // Publishes a message to the bridge
    rpc Publish (BridgeMessage) returns (PublishResponse);
    // Publishes a batch of messages using a client stream
    rpc PublishBatch (stream BridgeMessage) returns (PublishResponse);
    // Subscribes to a stream of messages from the bridge
    rpc Subscribe (SubscribeRequest) returns (stream BridgeMessage);
}

message BridgeMessage {
    bytes payload = 1;
    string id = 2;
    map<string, string> metadata = 3;
}

message PublishResponse {
    bool success = 1;
    string error = 2;
}

message SubscribeRequest {
    string topic = 1;
}