File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
projects/client/RabbitMQ.Client/src/client/impl Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -86,7 +86,7 @@ public SocketFrameHandler_0_9(AmqpTcpEndpoint endpoint)
86
86
m_socket . GetStream ( ) ;
87
87
88
88
m_reader = new NetworkBinaryReader ( netstream ) ;
89
- m_writer = new NetworkBinaryWriter ( netstream ) ;
89
+ m_writer = new NetworkBinaryWriter ( new BufferedStream ( netstream ) ) ;
90
90
}
91
91
92
92
public AmqpTcpEndpoint Endpoint
@@ -118,6 +118,7 @@ public void SendHeader()
118
118
m_writer . Write ( ( byte ) 1 ) ;
119
119
m_writer . Write ( ( byte ) m_endpoint . Protocol . MajorVersion ) ;
120
120
m_writer . Write ( ( byte ) m_endpoint . Protocol . MinorVersion ) ;
121
+ m_writer . Flush ( ) ;
121
122
}
122
123
}
123
124
@@ -134,6 +135,7 @@ public void WriteFrame(Frame frame)
134
135
lock ( m_writer )
135
136
{
136
137
frame . WriteTo ( m_writer ) ;
138
+ m_writer . Flush ( ) ;
137
139
//Console.WriteLine("OUTBOUND:");
138
140
//DebugUtil.DumpProperties(frame, Console.Out, 2);
139
141
}
You can’t perform that action at this time.
0 commit comments