From c261d427aedc6a2c1abfc31ca7d43336cb63ccc3 Mon Sep 17 00:00:00 2001 From: alex Date: Sun, 8 Jan 2023 21:05:57 +0100 Subject: [PATCH] implement gorabbitmq v1.0.24 --- go.mod | 2 +- go.sum | 2 ++ modules/rabbitmq/rabbitmq.go | 2 ++ 3 files changed, 5 insertions(+), 1 deletion(-) diff --git a/go.mod b/go.mod index 7e5bc08..566d4d7 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module clickandjoin.app/websocketserver go 1.19 require ( - git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.23 // indirect + git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.24 // indirect github.com/andybalholm/brotli v1.0.4 // indirect github.com/fasthttp/websocket v1.5.0 // indirect github.com/gocql/gocql v1.3.1 // indirect diff --git a/go.sum b/go.sum index 4e5653b..213120c 100644 --- a/go.sum +++ b/go.sum @@ -38,6 +38,8 @@ git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.22 h1:26wm+XTVN git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.22/go.mod h1:KPbHNtFhttE/TtXZcorq6LKpCigkTaF0qzmB2p7nFsg= git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.23 h1:FYMFWE9gXAXtvLzyVmv9yp/AmQos1OfTuVZy6DnQrEw= git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.23/go.mod h1:KPbHNtFhttE/TtXZcorq6LKpCigkTaF0qzmB2p7nFsg= +git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.24 h1:rvBwQLc5keM6kkAGL9qNQiOlvT5GDfgnYDn3viHVDR8= +git.clickandjoin.umbach.dev/ClickandJoin/go-rabbitmq-client v1.0.24/go.mod h1:KPbHNtFhttE/TtXZcorq6LKpCigkTaF0qzmB2p7nFsg= github.com/andybalholm/brotli v1.0.4 h1:V7DdXeJtZscaqfNuAdSRuRFzuiKlHSC/Zh3zl9qY3JY= github.com/andybalholm/brotli v1.0.4/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig= github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932/go.mod h1:NOuUCSz6Q9T7+igc/hlvDOUdtWKryOrtFyIVABv/p7k= diff --git a/modules/rabbitmq/rabbitmq.go b/modules/rabbitmq/rabbitmq.go index 2a38b39..60a8a52 100644 --- a/modules/rabbitmq/rabbitmq.go +++ b/modules/rabbitmq/rabbitmq.go @@ -31,6 +31,7 @@ func Init() { WebsocketClient = gorabbitmqclient.NewClient( cfg.Debug, gorabbitmqclient.ExchangeSettings{ + Enabled: true, Name: exchangeWebsocketMessages, Type: "direct", Durable: true, @@ -61,6 +62,7 @@ func Init() { cfg.Debug, gorabbitmqclient.ExchangeSettings{}, gorabbitmqclient.QueueSettings{ + Enabled: true, Name: "", Durable: false, DeleteWhenUnused: false,