From b25748c81a4af26f48bc379fe2a1145ca4893ddd Mon Sep 17 00:00:00 2001 From: Christina Date: Wed, 4 Mar 2026 13:59:26 +0100 Subject: [PATCH] use correct portnr --- spec/spec_helper.cr | 2 +- src/amqproxy/server.cr | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/spec/spec_helper.cr b/spec/spec_helper.cr index 7beeb61..23bcfa3 100644 --- a/spec/spec_helper.cr +++ b/spec/spec_helper.cr @@ -46,7 +46,7 @@ end def verify_running_amqp! tls = UPSTREAM_URL.scheme == "amqps" host = UPSTREAM_URL.host || "127.0.0.1" - port = UPSTREAM_URL.port || 5762 + port = UPSTREAM_URL.port || 5672 port = 5671 if tls && UPSTREAM_URL.port.nil? TCPSocket.new(host, port, connect_timeout: 3.seconds).close rescue Socket::ConnectError diff --git a/src/amqproxy/server.cr b/src/amqproxy/server.cr index fe04409..2ba59ee 100644 --- a/src/amqproxy/server.cr +++ b/src/amqproxy/server.cr @@ -15,7 +15,7 @@ module AMQProxy def self.new(url : URI) tls = url.scheme == "amqps" host = url.host || "127.0.0.1" - port = url.port || 5762 + port = url.port || 5672 port = 5671 if tls && url.port.nil? idle_connection_timeout = url.query_params.fetch("idle_connection_timeout", 5).to_i new(host, port, tls, idle_connection_timeout)