- Add new internal plugin - channel. Which used to deliver messages from

  the ws plugin to the http directly

Signed-off-by: Valery Piashchynski <[email protected]>

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