syntax = "proto3"; package servicepb; option go_package="go.unistack.org/micro-broker-service/v3/proto;servicepb"; service Broker { rpc Publish(PublishRequest) returns (Empty) {}; rpc Subscribe(SubscribeRequest) returns (stream Message) {}; } message Empty {} message PublishRequest { string topic = 1; Message message = 2; } message SubscribeRequest { string topic = 1; string group = 2; } message Message { map header = 1; bytes body = 2; }