diff options
Diffstat (limited to 'pkg/pubsub/interface.go')
| -rw-r--r-- | pkg/pubsub/interface.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/pkg/pubsub/interface.go b/pkg/pubsub/interface.go index caf8783f..18c1a80c 100644 --- a/pkg/pubsub/interface.go +++ b/pkg/pubsub/interface.go @@ -1,5 +1,7 @@ package pubsub +import "github.com/spiral/roadrunner/v2/pkg/pubsub/message" + // PubSub ... type PubSub interface { Publisher @@ -19,14 +21,14 @@ 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 type Reader interface { - Next() (*Message, error) + Next() (*message.Message, error) } |