diff options
Diffstat (limited to 'plugins/broadcast/plugin.go')
| -rw-r--r-- | plugins/broadcast/plugin.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/plugins/broadcast/plugin.go b/plugins/broadcast/plugin.go index 45051a7f..f1ea258e 100644 --- a/plugins/broadcast/plugin.go +++ b/plugins/broadcast/plugin.go @@ -12,7 +12,7 @@ const ( ) type Plugin struct { - broker Broker + broker Subscriber log logger.Logger cfg *Config @@ -53,6 +53,7 @@ func (p *Plugin) Serve() chan error { errCh <- errors.E(op, err) } }() + return errCh } @@ -76,7 +77,7 @@ func (p *Plugin) Collects() []interface{} { } } -func (p *Plugin) CollectBroker(name endure.Named, broker Broker) { +func (p *Plugin) CollectBroker(name endure.Named, broker Subscriber) { p.broker = broker } |