|
|
| Author |
Message |
|
| Guest |
 Posted: Wed Mar 19, 2008 10:16 am |
 |
|
|
Guest
|
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??
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss@lists.rabbitmq.com
http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
Post recived from mailinglist |
|
|
| Back to top |
|
| Guest |
| Posted: Mon Mar 24, 2008 6:02 pm |
|
|
|
Guest
|
Michel,
Michel Polder wrote:
> 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:
> [...]
> at RabbitMQ.Client.Impl.ModelBase.AccessRequest(String realm)
> at RabbitMQ.Client.Examples.LogTail.Main(String[] args)
IIRC OpenAMQ does not support the AMQP access class and, furthermore,
simply closes the socket when it receives an access.request rather than
reporting an error.
To get around that, suppress the access.request methods with the
RabbitMQ.Client.ConnectionParameters.AccessRequestConfig property.
Regards,
Matthias.
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss@lists.rabbitmq.com
http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
Post recived from mailinglist |
|
|
| Back to top |
|
| Guest |
| Posted: Mon Mar 24, 2008 7:30 pm |
|
|
|
Guest
|
Michel,
Matthias Radestock wrote:
> To get around that, suppress the access.request methods with the
> RabbitMQ.Client.ConnectionParameters.AccessRequestConfig property.
You can also achieve the same effect by setting the AMQP_ACCESS_REQUEST
environment variable to SUPPRESS, which means you can run the program
unmodified, e.g. with
export AMQP_ACCESS_REQUEST=SUPPRESS; ./myprogram
(the exact syntax differs depending on your shell, obviously).
Matthias.
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss@lists.rabbitmq.com
http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
Post recived from mailinglist |
|
|
| Back to top |
|
|
|
All times are GMT
|
|
You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum
You cannot attach files in this forum
You cannot download files in this forum
|
|
|
Digg It
Del.icio.us
Reddit
Facebook
Stumble Upon
Technorati
