svn commit: r1371517 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs

[ta...@apache.org]

Author: tabish
Date: Thu Aug  9 22:22:21 2012
New Revision: 1371517

URL: http://svn.apache.org/viewvc?rev=1371517&view=rev
Log:
https://issues.apache.org/jira/browse/AMQNET-391

should actually apply the settings too.  

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=1371517&r1=1371516&r2=1371517&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 Thu Aug  9 22:22:21 2012
@@ -112,8 +112,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(new BufferedStream(CreateSocketStream()));
-					socketReader = new EndianBinaryReader(new BufferedStream(CreateSocketStream()));
+					socketWriter = new EndianBinaryWriter(new BufferedStream(CreateSocketStream(), sendBufferSize));
+					socketReader = new EndianBinaryReader(new BufferedStream(CreateSocketStream(), receiveBufferSize));
 
 					// now lets create the background read thread
 					readThread = new Thread(new ThreadStart(ReadLoop)) { IsBackground = true };