From 9b0586cba73ff5a7de1c5f002b3fd15d0083ad08 Mon Sep 17 00:00:00 2001
From: SALLEYRON Julien <julien.salleyron@gmail.com>
Date: Mon, 12 Nov 2018 09:52:03 +0100
Subject: [PATCH] Verify ctx when we send configuration message in docker
 provider

---
 provider/docker/docker.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/provider/docker/docker.go b/provider/docker/docker.go
index fc7bb84a1..1749a6fa3 100644
--- a/provider/docker/docker.go
+++ b/provider/docker/docker.go
@@ -210,10 +210,15 @@ func (p *Provider) Provide(configurationChan chan<- types.ConfigMessage, pool *s
 						}
 						configuration := p.buildConfiguration(containers)
 						if configuration != nil {
-							configurationChan <- types.ConfigMessage{
+							message := types.ConfigMessage{
 								ProviderName:  "docker",
 								Configuration: configuration,
 							}
+							select {
+							case configurationChan <- message:
+							case <-ctx.Done():
+							}
+
 						}
 					}