diff options
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/pubsub/interface.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/pkg/pubsub/interface.go b/pkg/pubsub/interface.go index 63a12b34..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 @@ -28,5 +30,5 @@ type Publisher interface { // Reader interface should return next message type Reader interface { - Next() (*Message, error) + Next() (*message.Message, error) } |