fixup! Channel pool

cloudamqp · Feb 17, 2024 · b79013d · b79013d
1 parent e9444fa
commit b79013d
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 10 deletions.
diff --git a/spec/amqproxy_spec.cr b/spec/amqproxy_spec.cr
@@ -13,7 +13,6 @@ describe AMQProxy::Server do
           s.client_connections.should eq 1
           s.upstream_connections.should eq 1
         end
-        # sleep 0.1
       end
       s.client_connections.should eq 0
       s.upstream_connections.should eq 1

diff --git a/src/amqproxy/client.cr b/src/amqproxy/client.cr
@@ -4,15 +4,6 @@ require "./version"
 require "./upstream"
 require "./records"
 
-# Be able to overwrite channel id
-module AMQ
-  module Protocol
-    abstract struct Frame
-      setter channel
-    end
-  end
-end
-
 module AMQProxy
   class Client
     getter credentials : Credentials

diff --git a/src/amqproxy/records.cr b/src/amqproxy/records.cr
@@ -26,3 +26,12 @@ module AMQProxy
 
   record Credentials, user : String, password : String, vhost : String
 end
+
+# Be able to overwrite channel id
+module AMQ
+  module Protocol
+    abstract struct Frame
+      setter channel
+    end
+  end
+end