diff options
| author | Valery Piashchynski <[email protected]> | 2021-06-01 14:57:33 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-06-01 14:57:33 +0300 |
| commit | 352b0f7cfcc1beaeb4d66777f30732f4003ce6d2 (patch) | |
| tree | d940de0ee304d3edb60daa35568c3f186dc6a8b5 /pkg/pubsub/interface.go | |
| parent | 548ee4432e48b316ada00feec1a6b89e67ae4f2f (diff) | |
- Initial commit
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/pubsub/interface.go')
| -rw-r--r-- | pkg/pubsub/interface.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/pubsub/interface.go b/pkg/pubsub/interface.go index caf8783f..63a12b34 100644 --- a/pkg/pubsub/interface.go +++ b/pkg/pubsub/interface.go @@ -19,11 +19,11 @@ type Subscriber interface { // Publisher publish one or more messages type Publisher interface { // Publish one or multiple Channel. - Publish(messages []*Message) error + Publish(messages []byte) error // PublishAsync publish message and return immediately // If error occurred it will be printed into the logger - PublishAsync(messages []*Message) + PublishAsync(messages []byte) } // Reader interface should return next message |