Wired up the database consumer and the event aggreagator to the main func in the coordinator package.

Author: rahul-dhar-e5609

src/distributed/coordinator/exec/main.go

@@ -5,8 +5,16 @@ import (
 	"fmt"
 )
 
+var dc *coordinator.DatabaseConsumer
+
 func main() {
-	ql := coordinator.NewQueueListener()
+
+	// wiring event aggreagtor to coordinator package
+	ea := coordinator.NewEventAggregator()
+	// instantiating package level databse consumer
+	dc := coordinator.NewDataConsumer(ea)
+
+	ql := coordinator.NewQueueListener(ea)
 	go ql.ListenForNewSource()
 
 	var a string

src/distributed/coordinator/queuelistener.go

@@ -32,11 +32,11 @@ type QueueListener struct {
 // NewQueueListener is a constructor function
 // that ensures that the QueueListener is
 // properly initialized
-func NewQueueListener() *QueueListener {
+func NewQueueListener(ea *EventAggregator) *QueueListener {
 	//instantiating new object of queuelistener
 	ql := QueueListener{
 		sources: make(map[string]<-chan amqp.Delivery),
-		ea:      NewEventAggregator(),
+		ea:      ea,
 	}
 
 	//populating the Connection and Channel fields