summaryrefslogtreecommitdiff
path: root/plugins/broadcast/rpc.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/broadcast/rpc.go')
-rw-r--r--plugins/broadcast/rpc.go26
1 files changed, 0 insertions, 26 deletions
diff --git a/plugins/broadcast/rpc.go b/plugins/broadcast/rpc.go
deleted file mode 100644
index 948fd7ae..00000000
--- a/plugins/broadcast/rpc.go
+++ /dev/null
@@ -1,26 +0,0 @@
-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() {
-
-}