diff options
Diffstat (limited to 'pkg/pubsub/interface.go')
| -rw-r--r-- | pkg/pubsub/interface.go | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/pkg/pubsub/interface.go b/pkg/pubsub/interface.go index 80dab0c3..caf8783f 100644 --- a/pkg/pubsub/interface.go +++ b/pkg/pubsub/interface.go @@ -11,6 +11,7 @@ type PubSub interface { type Subscriber interface { // Subscribe broker to one or multiple topics. Subscribe(topics ...string) error + // Unsubscribe from one or multiply topics Unsubscribe(topics ...string) error } @@ -18,21 +19,14 @@ type Subscriber interface { // Publisher publish one or more messages type Publisher interface { // Publish one or multiple Channel. - Publish(messages []Message) error + Publish(messages []*Message) error // PublishAsync publish message and return immediately // If error occurred it will be printed into the logger - PublishAsync(messages []Message) + PublishAsync(messages []*Message) } // Reader interface should return next message type Reader interface { - Next() (Message, error) -} - -type Message interface { - Command() string - Payload() []byte - Topics() []string - Broker() string + Next() (*Message, error) } |