504 channel/connection is not open after a few minutes

[Jamalianpour]

Hello,
I have one channel with 2 queue and after a few minutes (about 15 minutes) I got 504 error :
Exception (504) Reason: channel/connection is not open
My code:

RabbitConnection, err := rabbitmq.Dial("amqp://" + username + ":" + password + "@" + host + "/")
if err != nil {
	return err
}

//conn.Close()
RabbitChannel, err = RabbitConnection.Channel()
if err != nil {
	return err
}
//RabbitChannel.Close()

_, err = RabbitChannel.QueueDeclare(
	LsQueue, // name
	true,   // durable
	false,   // delete when unused
	false,   // exclusive
	false,   // no-wait
	nil,     // arguments
)
_, err = RabbitChannel.QueueDeclare(
	CoreQueue, // name
	true,     // durable
	false,     // delete when unused
	false,     // exclusive
	false,     // no-wait
	nil,       // arguments
)

err = RabbitChannel.Confirm(false)
if err != nil {
	return err
}

[lukebakken]

The code you provided does not compile as-is, nor is it runnable. You must provide code that I can compile and run, with instructions on how to run it. We don't have time to guess how to reproduce your issue.

Based on the incomplete set of code you provided, there should be no issue.

Please let us know what RabbitMQ logs at the time of the error.

[Jamalianpour]

WOW
I don't have time like you :| You work on this repository and I think you should resolve issues.
any way my runnable code is this:

package main

import (
	rabbitmq "github.com/rabbitmq/amqp091-go"
       "github.com/joho/godotenv"
	"log"
	"os"
	"strings"
)

var RabbitChannel *rabbitmq.Channel
var RabbitConnection *rabbitmq.Connection
var LsQueue string
var CoreQueue string

func main() {
        err := godotenv.Load(".env")
	if err != nil {
		log.Fatalf("Error loading .env file")
	}

	_ = InitRabbitMQ()
	defer service.RabbitConnection.Close()
	defer service.RabbitChannel.Close()
}

func InitRabbitMQ() error {
	username := os.Getenv("RUSERNAME")
	password := os.Getenv("RPASSWORD")
	host := os.Getenv("RHOST")
	LsQueue = os.Getenv("LSQueue")
	CoreQueue = os.Getenv("COREQueue")
	RabbitConnection, err := rabbitmq.Dial("amqp://" + username + ":" + password + "@" + host + "/")
	if err != nil {
		return err
	}

	RabbitChannel, err = RabbitConnection.Channel()
	if err != nil {
		return err
	}

	_, err = RabbitChannel.QueueDeclare(
		LsQueue, 
		false,   
		false,   
		false,   
		false,   
		nil,     
	)

	_, err = RabbitChannel.QueueDeclare(
		CoreQueue, 
		false,     
		false,     
		false,     
		false,     
		nil,       
	)

	err = RabbitChannel.Confirm(false)

	if err != nil {
		return err
	}
	log.Println("Connect to rabbitMQ successfully")
	return nil
}

func RPublishToCore(body string) error {
	body = strings.ReplaceAll(body, "\"", "\\\"")
	err := RabbitChannel.Publish(
		"",        
		CoreQueue, 
		false,     
		false,     
		amqp.Publishing{
			DeliveryMode: amqp.Persistent,
			ContentType:  "application/json",
			Body:         []byte("\"" + body + "\""),
		})
	if err != nil {
		log.Println(err)
	}
	return err
}

[lukebakken]

WOW I don't have time like you :| You work on this repository and I think you should resolve issues.

Yes, we will resolve issues or answer questions when we have something to work with. Providing code that runs is the bare minimum necessary. Your code still does not compile and run as provided above. See the repository I created here:

https://github.com/lukebakken/amqp091-go_gh-104

Notice that I had to add modules and fix compilation errors in your code (amqp is not defined, it should be rabbitmq).

Output of go build:

> go build
# example.com/m/v2
.\main.go:23:8: undefined: service
.\main.go:24:8: undefined: service

So, instead of working on your problem I continue to have to figure out how to reproduce it.

---

Please answer the question I asked above:

Please let us know what RabbitMQ logs at the time of the error.

[Jamalianpour]

So, instead of working on your problem I continue to have to figure out how to reproduce it.

Sorry about code ...

But I think found the problem by checking RabbitMQ logs.

2022-07-17 07:01:09.578 [info] <0.8046.0> accepting AMQP connection <0.8046.0> ([::1]:1879 -> [::1]:5672)
2022-07-17 07:01:09.582 [info] <0.8046.0> connection <0.8046.0> ([::1]:1879 -> [::1]:5672): user 'guest' authenticated and granted access to vhost '/'
2022-07-17 07:02:59.752 [error] <0.8046.0> closing AMQP connection <0.8046.0> ([::1]:1879 -> [::1]:5672):
missed heartbeats from client, timeout: 10s

When I try to debug program and put breakpoint in my code after 10s RabbitMQ missed heartbeats and close the connection.

Code dose not required any more but I fix code to compile and run without error:

package main

import (
	"github.com/joho/godotenv"
	rabbitmq "github.com/rabbitmq/amqp091-go"
	"log"
	"os"
	"strings"
)

var RabbitChannel *rabbitmq.Channel
var RabbitConnection *rabbitmq.Connection
var LsQueue string
var CoreQueue string

func main() {
	err := godotenv.Load(".env")
	if err != nil {
		log.Fatalf("Error loading .env file")
	}

	_ = InitRabbitMQ()
	select {}
}

func InitRabbitMQ() error {
	username := os.Getenv("RUSERNAME")
	password := os.Getenv("RPASSWORD")
	host := os.Getenv("RHOST")
	LsQueue = os.Getenv("LSQueue")
	CoreQueue = os.Getenv("COREQueue")
	RabbitConnection, err := rabbitmq.Dial("amqp://" + username + ":" + password + "@" + host + "/")
	if err != nil {
		return err
	}

	RabbitChannel, err = RabbitConnection.Channel()
	if err != nil {
		return err
	}

	_, err = RabbitChannel.QueueDeclare(
		LsQueue,
		false,
		false,
		false,
		false,
		nil,
	)

	_, err = RabbitChannel.QueueDeclare(
		CoreQueue,
		false,
		false,
		false,
		false,
		nil,
	)

	err = RabbitChannel.Confirm(false)

	if err != nil {
		return err
	}
	log.Println("Connect to rabbitMQ successfully")
	return nil
}

func RPublishToCore(body string) error {
	body = strings.ReplaceAll(body, "\"", "\\\"")
	err := RabbitChannel.Publish(
		"",
		CoreQueue,
		false,
		false,
		rabbitmq.Publishing{
			DeliveryMode: rabbitmq.Persistent,
			ContentType:  "application/json",
			Body:         []byte("\"" + body + "\""),
		})
	if err != nil {
		log.Println(err)
	}
	return err
}

[lukebakken]

When I try to debug program and put breakpoint in my code after 10s RabbitMQ missed heartbeats and close the connection.

Thanks for following up. Sorry if I seemed impatient, it's just that I do want to help people out but they need to "help me help them" as well 😄

If you find yourself debugging your code a lot, feel free to request a much longer heartbeat interval by using the DialConfig function.