|
@@ -21,7 +21,7 @@ func runOutput(input chan types.Event, overflow chan types.Event, holders []leak
|
|
|
LOOP:
|
|
LOOP:
|
|
|
for {
|
|
for {
|
|
|
select {
|
|
select {
|
|
|
- case <-bucketsTomb.Dying():
|
|
|
|
|
|
|
+ case <-outputsTomb.Dying():
|
|
|
log.Infof("Flushing outputs")
|
|
log.Infof("Flushing outputs")
|
|
|
output.FlushAll()
|
|
output.FlushAll()
|
|
|
log.Infof("Shuting down output routines")
|
|
log.Infof("Shuting down output routines")
|
Thibault bui Koechlin