diff --git a/resources/aws_ec2.go b/resources/aws_ec2.go
index f9693ccb..3c9a7c58 100644
--- a/resources/aws_ec2.go
+++ b/resources/aws_ec2.go
@@ -632,7 +632,6 @@ func (obj *AwsEc2Res) snsWatch() error {
 	send := false
 	var exit *error
 	defer obj.wg.Wait()
-	defer close(obj.closeChan)
 	// create the sns listener
 	// closing is handled by http.Server.Shutdown in the defer func below
 	listener, err := obj.snsListener(obj.WatchListenAddr)
@@ -655,6 +654,7 @@ func (obj *AwsEc2Res) snsWatch() error {
 			log.Printf("%s: sns server shutdown cancelled", obj)
 		}
 	}()
+	defer close(obj.closeChan)
 	obj.wg.Add(1)
 	// start the sns server
 	go func() {