diff --git a/contrib/codecs/broker/broker.go b/contrib/codecs/broker/broker.go index 453847e0149fadf298f882608d9fae8a7862ea3f..bac583928eb6c44a2f6914b601c27423ad63a1cd 100644 --- a/contrib/codecs/broker/broker.go +++ b/contrib/codecs/broker/broker.go @@ -19,6 +19,10 @@ type Broker interface { ClientSpoke } +type Replier interface { + Send(json.RawMessage) +} + type Subscription interface { // channel that will close when done or error Listen() <-chan json.RawMessage