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 };
