diff options
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 |