fixes
This commit is contained in:
parent
039ed1a7eb
commit
70c6ee7ddb
1 changed files with 1 additions and 0 deletions
|
@ -111,6 +111,7 @@ func (s *Sync) FullCycle() error {
|
||||||
signal.Notify(interruptChan, os.Interrupt, syscall.SIGTERM)
|
signal.Notify(interruptChan, os.Interrupt, syscall.SIGTERM)
|
||||||
go func() {
|
go func() {
|
||||||
<-interruptChan
|
<-interruptChan
|
||||||
|
log.Println("Got interrupt signal. Will shut down after current publishes finish")
|
||||||
s.stop.Stop()
|
s.stop.Stop()
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue