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

[ta...@apache.org]

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