diff options
Diffstat (limited to 'plugins/broadcast/plugin.go')
| -rw-r--r-- | plugins/broadcast/plugin.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/plugins/broadcast/plugin.go b/plugins/broadcast/plugin.go index f1ea258e..ec7c2587 100644 --- a/plugins/broadcast/plugin.go +++ b/plugins/broadcast/plugin.go @@ -13,6 +13,7 @@ const ( type Plugin struct { broker Subscriber + driver Storage log logger.Logger cfg *Config @@ -48,17 +49,16 @@ func (p *Plugin) Serve() chan error { // start the underlying broker go func() { - err := p.broker.Serve() - if err != nil { - errCh <- errors.E(op, err) - } + // err := p.broker.Serve() + // if err != nil { + // errCh <- errors.E(op, err) + // } }() return errCh } func (p *Plugin) Stop() error { - return nil } |