create config to rabbitmq

Prrromanssss · Feb 13, 2024 · 15e1944 · 15e1944
1 parent 61681f9
commit 15e1944
Show file tree

Hide file tree

Showing 28 changed files with 8,455 additions and 1 deletion.
diff --git a/.env.example b/.env.example
@@ -1,2 +1,3 @@
 PORT=YOUR-SITE-PORT
-DB_URL=YOUR-DB-CONNECTION-URL
+DB_URL=YOUR-DB-CONNECTION-URL
+RABBITMQ_URL=YOUR-RABBITMQ-CONNECTION-URL
diff --git a/backend/config/rabbitmq_config.go b/backend/config/rabbitmq_config.go
@@ -0,0 +1,30 @@
+package config
+
+import (
+	"log"
+
+	"github.com/streadway/amqp"
+)
+
+type AMQPConfig struct {
+	Conn *amqp.Connection
+	Ch   *amqp.Channel
+}
+
+func NewConsumerAMQPConfig(amqpUrl string) *AMQPConfig {
+	conn, err := amqp.Dial(amqpUrl)
+	if err != nil {
+		log.Fatalf("Can't connect to RabbitMQ: %v", err)
+	}
+
+	log.Println("Successfully connected to RabbitMQ instance")
+
+	ch, err := conn.Channel()
+	if err != nil {
+		log.Fatalf("Can't create a channel from RabbitMQ: %v", err)
+	}
+	return &AMQPConfig{
+		Conn: conn,
+		Ch:   ch,
+	}
+}
diff --git a/backend/go.mod b/backend/go.mod
@@ -11,3 +11,5 @@ require (
 require github.com/google/uuid v1.6.0
 
 require github.com/lib/pq v1.10.9
+
+require github.com/streadway/amqp v1.1.0
diff --git a/backend/go.sum b/backend/go.sum
@@ -8,3 +8,5 @@ github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
 github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
+github.com/streadway/amqp v1.1.0 h1:py12iX8XSyI7aN/3dUT8DFIDJazNJsVJdxNVEpnQTZM=
+github.com/streadway/amqp v1.1.0/go.mod h1:WYSrTEYHOXHd0nwFeUXAe2G2hRnQT+deZJJf88uS9Bg=
diff --git a/backend/vendor/github.com/streadway/amqp/.gitignore b/backend/vendor/github.com/streadway/amqp/.gitignore
diff --git a/backend/vendor/github.com/streadway/amqp/.travis.yml b/backend/vendor/github.com/streadway/amqp/.travis.yml
diff --git a/backend/vendor/github.com/streadway/amqp/CONTRIBUTING.md b/backend/vendor/github.com/streadway/amqp/CONTRIBUTING.md
diff --git a/backend/vendor/github.com/streadway/amqp/LICENSE b/backend/vendor/github.com/streadway/amqp/LICENSE
diff --git a/backend/vendor/github.com/streadway/amqp/README.md b/backend/vendor/github.com/streadway/amqp/README.md
diff --git a/backend/vendor/github.com/streadway/amqp/allocator.go b/backend/vendor/github.com/streadway/amqp/allocator.go
Original file line number	Diff line number	Diff line change
Expand Up		@@ -11,3 +11,5 @@ require (
		require github.com/google/uuid v1.6.0

		require github.com/lib/pq v1.10.9

		require github.com/streadway/amqp v1.1.0