Skip to content

Commit 5a8261b

Browse files
committed
send the correct protocol header for 0-9-x (x>0)
1 parent 905b3a6 commit 5a8261b

File tree

1 file changed

+14
-4
lines changed

1 file changed

+14
-4
lines changed

projects/client/RabbitMQ.Client/src/client/impl/SocketFrameHandler_0_9.cs

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,10 +156,20 @@ public void SendHeader()
156156
lock (m_writer)
157157
{
158158
m_writer.Write(Encoding.ASCII.GetBytes("AMQP"));
159-
m_writer.Write((byte)1);
160-
m_writer.Write((byte)1);
161-
m_writer.Write((byte)m_endpoint.Protocol.MajorVersion);
162-
m_writer.Write((byte)m_endpoint.Protocol.MinorVersion);
159+
if (m_endpoint.Protocol.Revision != 0)
160+
{
161+
m_writer.Write((byte)0);
162+
m_writer.Write((byte)m_endpoint.Protocol.MajorVersion);
163+
m_writer.Write((byte)m_endpoint.Protocol.MinorVersion);
164+
m_writer.Write((byte)m_endpoint.Protocol.Revision);
165+
}
166+
else
167+
{
168+
m_writer.Write((byte)1);
169+
m_writer.Write((byte)1);
170+
m_writer.Write((byte)m_endpoint.Protocol.MajorVersion);
171+
m_writer.Write((byte)m_endpoint.Protocol.MinorVersion);
172+
}
163173
m_writer.Flush();
164174
}
165175
}

0 commit comments

Comments
 (0)