From 0d99d4e4a5a813988abff057612f01ed685416f3 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 17:05:52 +0100 Subject: [PATCH 1/6] Update order_client.go --- order_client.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/order_client.go b/order_client.go index c6749d7..5f57258 100644 --- a/order_client.go +++ b/order_client.go @@ -24,12 +24,12 @@ type RabbitTransportClient struct { func (t *RabbitTransportClient) declareBindAndConsume(topic string) (<-chan amqp.Delivery, error) { q, err := t.channel.QueueDeclare( - "", // name - false, // durable - false, // delete when unused - true, // exclusive - false, // no-wait - nil, // arguments + "orders", // name + false, // durable + false, // delete when unused + true, // exclusive + false, // no-wait + nil, // arguments ) if err != nil { return nil, err From 4854db055ffa2c0c02f263521a533bb1f0be0387 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 17:28:11 +0100 Subject: [PATCH 2/6] Update order_client.go --- order_client.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/order_client.go b/order_client.go index 5f57258..8366396 100644 --- a/order_client.go +++ b/order_client.go @@ -24,12 +24,12 @@ type RabbitTransportClient struct { func (t *RabbitTransportClient) declareBindAndConsume(topic string) (<-chan amqp.Delivery, error) { q, err := t.channel.QueueDeclare( - "orders", // name - false, // durable - false, // delete when unused - true, // exclusive - false, // no-wait - nil, // arguments + "order-queue", // name + false, // durable + false, // delete when unused + true, // exclusive + false, // no-wait + nil, // arguments ) if err != nil { return nil, err @@ -69,7 +69,7 @@ func (t *RabbitTransportClient) Connect(handler UpdateHandler) error { if err != nil { return err } - log.Printf("Connected to rabbit upsert topic: %s", t.OrderTopic) + log.Printf("Connected to rabbit order topic: %s", t.OrderTopic) go func(msgs <-chan amqp.Delivery) { for d := range msgs { From c6f3f6e02d4f1ef4014cac6a4563e084f4326505 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 17:31:23 +0100 Subject: [PATCH 3/6] Update order_client.go --- order_client.go | 15 +++++---------- 1 file changed, 5 insertions(+), 10 deletions(-) diff --git a/order_client.go b/order_client.go index 8366396..53bd347 100644 --- a/order_client.go +++ b/order_client.go @@ -12,9 +12,7 @@ type UpdateHandler interface { } type RabbitTransportClient struct { - Url string - - OrderTopic string + Url string ClientName string handler UpdateHandler connection *amqp.Connection @@ -22,7 +20,7 @@ type RabbitTransportClient struct { quit chan bool } -func (t *RabbitTransportClient) declareBindAndConsume(topic string) (<-chan amqp.Delivery, error) { +func (t *RabbitTransportClient) declareBindAndConsume() (<-chan amqp.Delivery, error) { q, err := t.channel.QueueDeclare( "order-queue", // name false, // durable @@ -34,10 +32,7 @@ func (t *RabbitTransportClient) declareBindAndConsume(topic string) (<-chan amqp if err != nil { return nil, err } - err = t.channel.QueueBind(q.Name, topic, topic, false, nil) - if err != nil { - return nil, err - } + return t.channel.Consume( q.Name, "", @@ -65,11 +60,11 @@ func (t *RabbitTransportClient) Connect(handler UpdateHandler) error { } t.handler = handler t.channel = ch - toAdd, err := t.declareBindAndConsume(t.OrderTopic) + toAdd, err := t.declareBindAndConsume() if err != nil { return err } - log.Printf("Connected to rabbit order topic: %s", t.OrderTopic) + log.Printf("Connected to rabbit order topic") go func(msgs <-chan amqp.Delivery) { for d := range msgs { From 3fd7e348a816b3d1bb30ca9016459aa972c07219 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 17:33:56 +0100 Subject: [PATCH 4/6] why exclusive? --- order_client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/order_client.go b/order_client.go index 53bd347..d07d0d8 100644 --- a/order_client.go +++ b/order_client.go @@ -25,7 +25,7 @@ func (t *RabbitTransportClient) declareBindAndConsume() (<-chan amqp.Delivery, e "order-queue", // name false, // durable false, // delete when unused - true, // exclusive + false, // exclusive false, // no-wait nil, // arguments ) From 11b38ee89f3b7ad237b113a20f88af8573878abf Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 11 Nov 2025 17:37:26 +0100 Subject: [PATCH 5/6] cleanup --- main.go | 1 - 1 file changed, 1 deletion(-) diff --git a/main.go b/main.go index 667a6c0..5de4d8a 100644 --- a/main.go +++ b/main.go @@ -128,7 +128,6 @@ func main() { } client := &RabbitTransportClient{ Url: amqpUrl, - OrderTopic: "orders", ClientName: "OrderClient", } From 995b5f46810f5b3613bf5b621005bfbc0c58532a Mon Sep 17 00:00:00 2001 From: mats Date: Sun, 15 Feb 2026 12:31:10 +0100 Subject: [PATCH 6/6] =?UTF-8?q?fix(registry):=20knatofs.se=20=E2=86=92=20k?= =?UTF-8?q?6n.net?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .gitea/workflows/build.yaml | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/.gitea/workflows/build.yaml b/.gitea/workflows/build.yaml index eaf693a..eec523f 100644 --- a/.gitea/workflows/build.yaml +++ b/.gitea/workflows/build.yaml @@ -9,9 +9,9 @@ jobs: # - name: Check out repository code # uses: actions/checkout@v4 # - name: Build docker image -# run: docker build --progress=plain -t registry.knatofs.se/go-cart-actor-amd64:latest . +# run: docker build --progress=plain -t registry.k6n.net/go-cart-actor-amd64:latest . # - name: Push to registry -# run: docker push registry.knatofs.se/go-cart-actor-amd64:latest +# run: docker push registry.k6n.net/go-cart-actor-amd64:latest # - name: Deploy to Kubernetes # run: kubectl apply -f deployment/deployment.yaml -n cart # - name: Rollout amd64 deployment @@ -23,8 +23,8 @@ jobs: - name: Check out repository code uses: actions/checkout@v4 - name: Build docker image - run: docker build --progress=plain -t registry.knatofs.se/go-order-manager . + run: docker build --progress=plain -t registry.k6n.net/go-order-manager . - name: Push to registry - run: docker push registry.knatofs.se/go-order-manager + run: docker push registry.k6n.net/go-order-manager - name: Rollout arm64 deployment run: kubectl rollout restart deployment/order-manager-arm64 -n dev \ No newline at end of file