+ wg := new(sync.WaitGroup)
+
+ // add two goroutines to `wg` WaitGroup, one for each avilable server
+ wg.Add(2)
+
+ log.Debugf("Starting status callback server at port %v", configuration.InfoProducerSupervisionCallbackPort)
+ go func() {
+ server := server.CreateServer(configuration.InfoProducerSupervisionCallbackPort, server.StatusHandler)
+ log.Warn(server.ListenAndServe())
+ wg.Done()
+ }()
+
+ go func() {
+ server := server.CreateServer(configuration.InfoJobCallbackPort, server.CreateInfoJobHandler)
+ log.Warn(server.ListenAndServe())
+ wg.Done()
+ }()
+
+ // wait until WaitGroup is done
+ wg.Wait()
+ log.Debug("Stopping DMaaP Mediator Producer")