We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2823a9e commit 9c31483Copy full SHA for 9c31483
1 file changed
src/amqproxy/upstream.cr
@@ -39,11 +39,16 @@ module AMQProxy
39
end
40
41
def open_channel_for(downstream_channel : DownstreamChannel) : UpstreamChannel
42
+ upstream_channel = create_upstream_channel(downstream_channel)
43
+ send AMQ::Protocol::Frame::Channel::Open.new(upstream_channel.channel)
44
+ upstream_channel
45
+ end
46
+
47
+ private def create_upstream_channel(downstream_channel : DownstreamChannel)
48
@channels_lock.synchronize do
49
1_u16.upto(@channel_max) do |i|
50
unless @channels.has_key?(i)
51
@channels[i] = downstream_channel
- send AMQ::Protocol::Frame::Channel::Open.new(i)
52
return UpstreamChannel.new(self, i)
53
54
0 commit comments