Skip to content

G
GO Email Worker
Commit 23ec8c2a authored by Pasan Mallawaarachchi's avatar Pasan Mallawaarachchi 💻
Browse files
Options

thread running time change

parent 83b16729
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
worker.go
View file @ 23ec8c2a
...@@ -131,7 +131,7 @@ func main() { ...@@ -131,7 +131,7 @@ func main() {
if config.AppMod.Production == "0" { if config.AppMod.Production == "0" {
fmt.Println("Starting the Email Manager...") fmt.Println("Starting the Email Manager...")
} }
time.Sleep(time.Millisecond * 300) time.Sleep(time.Millisecond * 5000)
mailData = make(chan string) mailData = make(chan string)
outboxReadTime = make(chan string) outboxReadTime = make(chan string)
outboxDeleteTime = make(chan string) outboxDeleteTime = make(chan string)
...@@ -185,7 +185,7 @@ func main() { ...@@ -185,7 +185,7 @@ func main() {
// fmt.Println(string(respbody)) // fmt.Println(string(respbody))
fmt.Printf(" %s, %s, %s | ", resp.Status, strconv.Itoa(newDoc.TotalRows), time.Now().In(loc).String()) fmt.Printf(" %s, %s, %s | ", resp.Status, strconv.Itoa(newDoc.TotalRows), time.Now().In(loc).String())
logOutbox(resp.Status, strconv.Itoa(newDoc.TotalRows), time.Now().In(loc).String() /*string(respbody)*/) // logOutbox(resp.Status, strconv.Itoa(newDoc.TotalRows), time.Now().In(loc).String() /*string(respbody)*/)
//fmt.Printf("%s, %s, %s", resp.Status, strconv.Itoa(newDoc.TotalRows), string(respbody)) //fmt.Printf("%s, %s, %s", resp.Status, strconv.Itoa(newDoc.TotalRows), string(respbody))
/** /**
* if: the "OUTBOX" DB has new records, it returns the number of Rows * if: the "OUTBOX" DB has new records, it returns the number of Rows
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment