Send all GetOk frames in one TCP packet

Looks like rabbitmq-c might not support that the GetOk and Header frame comes in different TCP packets. #162 (comment)
cloudamqp · May 12, 2024 · b6cf9c7 · b6cf9c7
1 parent 7c89475
commit b6cf9c7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/amqproxy/client.cr b/src/amqproxy/client.cr
@@ -173,6 +173,7 @@ module AMQProxy
     private def expect_more_publish_frames?(frame) : Bool
       case frame
       when AMQ::Protocol::Frame::Basic::Publish then true
+      when AMQ::Protocol::Frame::Basic::GetOk   then true
       when AMQ::Protocol::Frame::Header         then frame.body_size != 0
       when AMQ::Protocol::Frame::Body           then frame.bytesize == @frame_max
       else                                           false