listener was being added on every loop, accumulating listeners

apigee_sync.go

diff --git a/apigee_sync.go b/apigee_sync.go
index 48f9743..f3912c6 100644
--- a/apigee_sync.go
+++ b/apigee_sync.go
@@ -174,7 +174,6 @@
 		/* If valid data present, Emit to plugins */
 		if len(resp.Changes) > 0 {
 			changeFinished = false
-			events.ListenFunc(apid.EventDeliveredSelector, postPluginDataDelivery)
 			events.Emit(ApigeeSyncEventSelector, &resp)
 			/*
 			 * The plugins should have finished what they are doing.
@@ -480,7 +479,6 @@
 		}
 
 		log.Info("Emitting Snapshot to plugins")
-		events.ListenFunc(apid.EventDeliveredSelector, postPluginDataDelivery)
 		events.Emit(ApigeeSyncEventSelector, &resp)
 
 		break

init.go

diff --git a/init.go b/init.go
index 0b3d8c8..b0c5add 100644
--- a/init.go
+++ b/init.go
@@ -82,6 +82,9 @@
 	 */
 	events.ListenFunc(apid.SystemEventsSelector, postInitPlugins)
 
+	// This callback function will get called after each data event delivery.
+	events.ListenFunc(apid.EventDeliveredSelector, postPluginDataDelivery)
+
 	// check for required values
 	for _, key := range []string{configProxyServerBaseURI, configConsumerKey, configConsumerSecret,
 		configSnapServerBaseURI, configChangeServerBaseURI} {