diff options
Diffstat (limited to 'plugins/broadcast/rpc.go')
-rw-r--r-- | plugins/broadcast/rpc.go | 26 |
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() { - -} |