go/microservices
1
0
Fork 0
mirror of https://github.com/ebosas/microservices.git synced 2025-08-24 20:08:55 +02:00
Code Issues Releases Activity

Parameters

Browse Source
This commit is contained in:
ebosas
2021-06-11 14:22:51 +03:00
parent 8bda3b097f
commit e6445daac7
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/backend/backend.go
View File

@@ -18,7 +18,7 @@ import (
var conf = config.New() var conf = config.New()
func main() { func main() {
fmt.Println("Running backend service") fmt.Println("[Backend service]")
// Establish a Rabbit connection. // Establish a Rabbit connection.
conn, err := rabbit.GetConn(conf.RabbitURL) conn, err := rabbit.GetConn(conf.RabbitURL)
@@ -53,7 +53,7 @@ func printMessages(d amqp.Delivery) bool {
// publishInput reads user input, marshals to json, and publishes to // publishInput reads user input, marshals to json, and publishes to
// a Rabbit exchange with the front-end and database routing keys. // a Rabbit exchange with the front-end and database routing keys.
func publishInput(conn *rabbit.Conn) { func publishInput(c *rabbit.Conn) {
reader := bufio.NewReader(os.Stdin) reader := bufio.NewReader(os.Stdin)
for { for {
input, _ := reader.ReadString('\n') input, _ := reader.ReadString('\n')
@@ -68,7 +68,7 @@ func publishInput(conn *rabbit.Conn) {
log.Fatalf("marshal message: %s", err) log.Fatalf("marshal message: %s", err)
} }
err = conn.Publish(conf.Exchange, conf.KeyFront+"."+conf.KeyDB, message) err = c.Publish(conf.Exchange, conf.KeyFront+"."+conf.KeyDB, message)
if err != nil { if err != nil {
log.Fatalf("publish message: %s", err) log.Fatalf("publish message: %s", err)
} }

6
cmd/database/database.go
View File

@@ -16,7 +16,7 @@ import (
var conf = config.New() var conf = config.New()
func main() { func main() {
fmt.Println("Running database service") fmt.Println("[Database service]")
// Postgres connection // Postgres connection
connP, err := pgx.Connect(context.Background(), conf.PostgresURL) connP, err := pgx.Connect(context.Background(), conf.PostgresURL)
@@ -46,14 +46,14 @@ func main() {
} }
// insertToDB inserts a Rabbit message into a Postgres database. // insertToDB inserts a Rabbit message into a Postgres database.
func insertToDB(d amqp.Delivery, connP *pgx.Conn) bool { func insertToDB(d amqp.Delivery, c *pgx.Conn) bool {
var message models.Message var message models.Message
err := json.Unmarshal(d.Body, &message) err := json.Unmarshal(d.Body, &message)
if err != nil { if err != nil {
log.Fatalf("unmarshal message: %s", err) log.Fatalf("unmarshal message: %s", err)
} }
_, err = connP.Exec(context.Background(), "insert into messages (message, created) values ($1, to_timestamp($2))", message.Text, message.Time/1000) _, err = c.Exec(context.Background(), "insert into messages (message, created) values ($1, to_timestamp($2))", message.Text, message.Time/1000)
if err != nil { if err != nil {
log.Fatalf("insert into database: %s", err) log.Fatalf("insert into database: %s", err)
} }