[rabbitmq-discuss] RabbitMQ .NET C# Client

Michel Polder michel.polder at quality-it.com
Wed Mar 19 10:15:24 GMT 2008


I'm trying to connect to a OpenAMQ 1.2c4 server with the logtail example
from the RabbitMQ.NET client. The "using (IModel ch = conn.CreateModel())"
line fails with the following exception:

RabbitMQ.Client.Exceptions.OperationInterruptedException: The AMQP operation was
 interrupted: AMQP close-reason, initiated by Library, code=541, text="Unexpecte
d Exception", classId=0, methodId=0, cause=System.IO.IOException: Unable to read
 data from the transport connection: A connection attempt failed because the con
nected party did not properly respond after a period of time, or established con
nection failed because connected host has failed to respond. ---> System.Net.Soc
kets.SocketException: A connection attempt failed because the connected party di
d not properly respond after a period of time, or established connection failed
because connected host has failed to respond
   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 System.IO.Stream.ReadByte()
   at System.IO.BinaryReader.ReadByte()
   at RabbitMQ.Client.Impl.Frame.ReadFrom(NetworkBinaryReader reader)
   at RabbitMQ.Client.Impl.SocketFrameHandler_0_9.ReadFrame()
   at RabbitMQ.Client.Impl.ConnectionBase.MainLoopIteration()
   at RabbitMQ.Client.Impl.ConnectionBase.MainLoop()
   at RabbitMQ.Client.Impl.SimpleBlockingRpcContinuation.GetReply()
   at RabbitMQ.Client.Impl.ModelBase.ModelRpc(MethodBase method,
ContentHeaderBase header, Byte[] body)
   at RabbitMQ.Client.Framing.Impl.v0_9.Model._Private_AccessRequest(String
realm, Boolean exclusive, Boolean passive, Boolean active, Boolean write,
Boolean read)
   at RabbitMQ.Client.Impl.ModelBase.AccessRequest(String realm, Boolean
exclusive, Boolean passive, Boolean active, Boolean write, Boolean read)
   at RabbitMQ.Client.Impl.ModelBase.AccessRequest(String realm)
   at RabbitMQ.Client.Examples.LogTail.Main(String[] args)

I'm using the following commandline for the logtail example (OpenAMQ server 
runs locally)

logtail 127.0.0.1:5672 PRICES topic PRC.*.*.*.*

Any idea what's going on??




More information about the rabbitmq-discuss mailing list