The code for these tests was hacked together in a bit of a hurry. It outputs information about whether the tests pass or not to log4net, so you have to browse the debug level log output to find out if the test passed or not.
Please add a line to print pass/fail to the console at an appropriate point in the TopicPublisher ( around line 143 and 147 where the Debug statements are). The exception you are seeing occurs after the test has passed when the publisher is closing its connection (I think). I don't know if I coded the connection close correctly or not. Take a look at the Shutdown method. Rupert On 3/21/07, Jonathan Anstey <[EMAIL PROTECTED]> wrote:
Hi all, I'm trying to use the Java broker with two .NET clients in a pub-sub arrangement. I figured a good starting point for the clients would be in Qpid.Client.Tests.interop. When I start the TopicListener, it connects to the Java broker without issue. When I start the TopicPublisher, it spits out the following exception: 2007-03-21 09:57:53,359 [976] WARN Qpid.Client.Protocol.AMQProtocolListener:OnException(146) - Protocol Listener received exception System.IO.IOException: Unable to read data from the transport connection: A blocking operation was interrupted by a call to WSACancelBlockingCall. ---> System.Net.Sockets.SocketException: A blocking operation was interrupted by a call to WSACancelBlockingCall at System.Net.Sockets.Socket.Receive(Byte[] buffer, Int32 offset, Int32 size, SocketFlags socketFlags) at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 size) --- End of inner exception stack trace --- at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 size) at Qpid.Client.Transport.Socket.Blocking.BlockingSocketProcessor.Read() in E:\dotnet\Qpid.Client\Client\Transport\Socket\Blocking\BlockingSocketProcessor.cs:line 88 at Qpid.Client.Transport.Socket.Blocking.ByteChannel.Read() in E:\dotnet\Qpid.Client\Client\Transport\Socket\Blocking\ByteChannel.cs:line 41 at Qpid.Client.Transport.AmqpChannel.Read() in E:\dotnet\Qpid.Client\Client\Transport\AmqpChannel.cs:line 52 at Qpid.Client.Transport.Socket.Blocking.BlockingSocketTransport.ReaderRunner.Run () in E:\dotnet\Qpid.Client\Client\Transport\Socket\Blocking\BlockingSocketTransport.cs:line 98 Can anyone shed any light on this? Also, are there anymore known interop issues with the .NET client and Java broker? Thanks! Jon
