1 files changed, 26 insertions, 0 deletions
diff --git a/plugins/broadcast/rpc.go b/plugins/broadcast/rpc.go
index aa270f64..92a2f368 100644
--- a/plugins/broadcast/rpc.go
+++ b/plugins/broadcast/rpc.go
@@ -1 +1,27 @@
 package broadcast
+
+import (
+	"github.com/spiral/errors"
+	"github.com/spiral/roadrunner/v2/plugins/logger"
+)
+
+type rpc struct {
+	log logger.Logger
+	svc *Plugin
+}
+
+
+func (r *rpc) Publish(msg []*Message, ok *bool) error {
+	const op = errors.Op("broadcast_publish")
+	err := r.svc.Publish(msg)
+	if err != nil {
+		*ok = false
+		return errors.E(op, err)
+	}
+	*ok = true
+	return nil
+}
+
+func (r *rpc) PublishAsync() {
+
+}