chtwrs/gocw2
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

testtest

Browse Source
This commit is contained in:
shoopea 2019-05-04 00:03:05 +08:00
parent 47691bc92b
commit 56f36d0503
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
main.go
View File

@ -105,12 +105,12 @@ func main() {
ownUserID64 = int64(OwnUserID(client)) ownUserID64 = int64(OwnUserID(client))
if *history { if *history {
fmt.Printf("Retrieving chat.\n")
go getHistory(client) go getHistory(client)
} }
go ListenCW(client)
fmt.Println("Started !") fmt.Println("Started !")
go ListenCW(client)
// Main loop // Main loop
for { for {

2
td.go
View File

@ -108,8 +108,6 @@ func getHistory(c *tdlib.Client) {
var msgCount int32 = 0 var msgCount int32 = 0
var lastMsgTime time.Time = time.Now() var lastMsgTime time.Time = time.Now()
fmt.Printf("Retrieving chat.\n")
conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Queue) conn, err := amqp.Dial("amqp://" + cfg.Rabbit.User + ":" + cfg.Rabbit.Password + "@" + cfg.Rabbit.Host + "/" + cfg.Rabbit.Queue)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)