You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2012/06/27 23:08:41 UTC
svn commit: r1354727 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
Author: tabish
Date: Wed Jun 27 21:08:40 2012
New Revision: 1354727
URL: http://svn.apache.org/viewvc?rev=1354727&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQNET-391
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs?rev=1354727&r1=1354726&r2=1354727&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs Wed Jun 27 21:08:40 2012
@@ -92,8 +92,8 @@ namespace Apache.NMS.ActiveMQ.Transport.
// Initialize our Read and Writer instances. Its not actually necessary
// to have two distinct NetworkStream instances but for now the TcpTransport
// will continue to do so for legacy reasons.
- socketWriter = new EndianBinaryWriter(CreateSocketStream());
- socketReader = new EndianBinaryReader(CreateSocketStream());
+ socketWriter = new EndianBinaryWriter(new BufferedStream(CreateSocketStream()));
+ socketReader = new EndianBinaryReader(new BufferedStream(CreateSocketStream()));
// now lets create the background read thread
readThread = new Thread(new ThreadStart(ReadLoop)) { IsBackground = true };