#698 feat(ws): replace `json` with binary flatbuffers

#698 feat(ws): replace `json` with binary flatbuffers

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)
 }