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

[tabish]

Author: tabish
Date: Thu Dec 10 16:42:04 2009
New Revision: 889321

URL: http://svn.apache.org/viewvc?rev=889321&view=rev
Log:
* TcpTransport.cs: 

Remove the creation of EndianBinaryReader/Writers as the Stomp data is streamed 
as a series of single byte value.

Modified:
    
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs

Modified: 
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
URL: 
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs?rev=889321&r1=889320&r2=889321&view=diff
==============================================================================
--- 
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
 (original)
+++ 
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
 Thu Dec 10 16:42:04 2009
@@ -85,8 +85,8 @@
 
                     // As reported in AMQ-988 it appears that NetworkStream is 
not thread safe
                     // so lets use an instance for each of the 2 streams
-                    socketWriter = new EndianBinaryWriter(new 
NetworkStream(socket));
-                    socketReader = new EndianBinaryReader(new 
NetworkStream(socket));
+                    socketWriter = new BinaryWriter(new NetworkStream(socket));
+                    socketReader = new BinaryReader(new NetworkStream(socket));
 
                     // now lets create the background read thread
                     readThread = new Thread(new ThreadStart(ReadLoop));