Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add docker-compose files for dmaap-mediator
[nonrtric.git]
/
dmaap-mediator-producer
/
main.go
diff --git
a/dmaap-mediator-producer/main.go
b/dmaap-mediator-producer/main.go
index
3fe92dc
..
47e12e9
100644
(file)
--- a/
dmaap-mediator-producer/main.go
+++ b/
dmaap-mediator-producer/main.go
@@
-76,7
+76,7
@@
func main() {
wg := new(sync.WaitGroup)
// add two goroutines to `wg` WaitGroup, one for each avilable server
wg := new(sync.WaitGroup)
// add two goroutines to `wg` WaitGroup, one for each avilable server
- wg.Add(
2
)
+ wg.Add(
3
)
log.Debugf("Starting status callback server at port %v", configuration.InfoProducerSupervisionCallbackPort)
go func() {
log.Debugf("Starting status callback server at port %v", configuration.InfoProducerSupervisionCallbackPort)
go func() {
@@
-91,6
+91,11
@@
func main() {
wg.Done()
}()
wg.Done()
}()
+ go func() {
+ jobs.RunJobs(fmt.Sprintf("%v:%v", configuration.MRHost, configuration.MRPort))
+ wg.Done()
+ }()
+
// wait until WaitGroup is done
wg.Wait()
log.Debug("Stopping DMaaP Mediator Producer")
// wait until WaitGroup is done
wg.Wait()
log.Debug("Stopping DMaaP Mediator Producer")