ну вот зачем простыни постить? плейграунд для чего придумали? gist?

forever := make(chan bool) go func() { for d := range msgs { log.Printf(" [*] Waiting for messages. To exit press CTRL+C") path, err = filepath.Abs(string(d.Body)) utils.Assert(err) if _, err = os.Stat(path); os.IsNotExist(err) { failOnError(err, "%s file doesn't exitst", d) } fmt.Println("Подошли к проверке") avast := AvScan(path, 60) fmt.Println("Прошел проверку") avastJSON, err := json.Marshal(avast) utils.Assert(err) fmt.Println(string(avastJSON)) db, err := sql.Open("mysql", "****") if err != nil { panic(err.Error()) // Just for example purpose. You should use proper error handling instead of panic } defer db.Close() sqlStatement := `INSERT INTO ResultTable (Module, Result, FileID) VALUES (?, ?, ?)` _, err = db.Exec(sqlStatement, "Comodo", avastJSON, "10") if err != nil { panic(err.Error()) // proper error handling instead of panic in your app } } }() <-forever } Данный скрипт принимает сообщения из очереди, не могу понять почему он виснет после приема первого сообщения...

в какой строке виснет?

Это антивирусная проверка, ей приходит название файла и запускается функция которая осуществляет его проверку. Первый файл принимает и в бд его отправляет, но второй уже не забирает из очереди

номер строки в которой Ваш код виснет?

forever := make(chan bool) go func() { for d := range msgs { log.Printf(" [*] Waiting for messages. To exit press CTRL+C") path, err = filepath.Abs(string(d.Body)) utils.Assert(err) if _, err = os.Stat(path); os.IsNotExist(err) { failOnError(err, "%s file doesn't exitst", d) } fmt.Println("Подошли к проверке") avast := AvScan(path, 60) fmt.Println("Прошел проверку") avastJSON, err := json.Marshal(avast) utils.Assert(err) fmt.Println(string(avastJSON)) db, err := sql.Open("mysql", "****") if err != nil { panic(err.Error()) // Just for example purpose. You should use proper error handling instead of panic } defer db.Close() sqlStatement := `INSERT INTO ResultTable (Module, Result, FileID) VALUES (?, ?, ?)` _, err = db.Exec(sqlStatement, "Comodo", avastJSON, "10") if err != nil { panic(err.Error()) // proper error handling instead of panic in your app } } }() <-forever } Данный скрипт принимает сообщения из очереди, не могу понять почему он виснет после приема первого сообщения...

Мда. Соменваюсь, что Вам кто-то что-то полезное скажет по сути до тех пор, пока вы не ответите на мой вопрос. Экстрасенсов тут нема.

а чего он не умеет нормально завершаться? типа того чтобы слушать сигнал и его обработать.

<-forever - ? Виснет очевидно потому, что не одна горутина не записывает в этот канал

Ему не нужно завершаться

это всё пофиг из чего вы что взяли. Если вы считываете из канала и не хотите чтобы в этом месте програма висла, вам надо в другой како-то горутине писать в этот канал. Это есть цимес каналов в Го. Вы тур оф го проходили?

надо пройти, иначе всё равно ничего путного не выйдет

так я же понятия не имею что вам надо. если просто бесконечный цикл, то конечно же ни какой канал не на фиг не нужен

какую задачу решает канал forever?

какую задачу решает канал forever?

Как я понял для асинхронного приема сообщений

Нет, он не решает. Для этого в другой горутине что-то должно отправляться в канал, а вашей функции должен быть асинхронный оператор select

а настройках amqp у тебя включен auto-ack?

или включи auto-ack если пофигу

для венды можно ?

они репортируют в брокер, что сообщение отбработано

хз

значит он ждет от тебя ack, nack или reject

делай в конце d.Ack() или d.Nack() после ошибок

в самом конце тела цикла

ack если все ок, nack если не ок

в ак ничего, а в нак почитай доку у метода

Artem иди работай

Туда же просто тру?

я думаю тебе нужен false

я думаю тебе нужен false