[rabbitmq-discuss] Receiving errno 10054 (WSAECONNRESET) writing to queue

[Sigurd Høgsbro]

Matthias,

I injected the java Tracer into the path, and spotted a Connection.tune
method with interesting parameters:

1265609050931: conn#0 ch#0 ->
{#method<connection.start-ok>(client-properties={library_version=0.6.1,
library=Python
amqplib},mechanism=AMQPLAIN,response=LOGINSguesPASSWORDSguest,locale=en_US),null,""}
1265609050961: conn#0 ch#0 <-
{#method<connection.tune>(channel-max=0,frame-max=131072,heartbeat=0),null,""}
1265609051002: conn#0 ch#0 ->
{#method<connection.tune-ok>(channel-max=65535,frame-max=131072,heartbeat=0),null,""}
1265609051003: conn#0 ch#0 ->
{#method<connection.open>(virtual-host=/,capabilities=,insist=false),null,""}
1265609051041: conn#0 ch#0 <-
{#method<connection.open-ok>(known-hosts=localhost:5672),null,""}
1265609051081: conn#0 ch#1 -> {#method<channel.open>(out-of-band=),null,""}
1265609051121: conn#0 ch#1 <- {#method<channel.open-ok>(),null,""}
1265609051161: conn#0 ch#1 ->
{#method<access.request>(realm=/data,exclusive=false,passive=false,active=true,write=true,read=false),null,""}
1265609051200: conn#0 ch#1 <- {#method<access.request-ok>(ticket=1),null,""}
1265609051242: conn#0 ch#2 -> {#method<channel.open>(out-of-band=),null,""}
1265609051290: conn#0 ch#2 <- {#method<channel.open-ok>(),null,""}
1265609051331: conn#0 ch#2 ->
{#method<access.request>(realm=/data,exclusive=false,passive=false,active=true,write=false,read=true),null,""}
1265609051370: conn#0 ch#2 <- {#method<access.request-ok>(ticket=1),null,""}
1265609051412: conn#0 ch#2 ->
{#method<queue.declare>(ticket=1,queue=transcode.wmal,passive=false,durable=false,exclusive=false,auto-delete=true,nowait=false,arguments={}),null,""}
1265609051451: conn#0 ch#2 <-
{#method<queue.declare-ok>(queue=transcode.wmal,message-count=0,consumer-count=0),null,""}
1265609051490: conn#0 ch#2 ->
{#method<basic.consume>(ticket=1,queue=transcode.wmal,consumer-tag=,no-local=false,no-ack=false,exclusive=false,nowait=false),null,""}
1265609051531: conn#0 ch#2 <-
{#method<basic.consume-ok>(consumer-tag=amq.ctag-GmOHWY3xtNeQ9+9WvAo3oA==),null,""}


This led me to the discussion on http://www.amqp.org/jira/browse/AMQP-108,
suggesting that there is an upper limit on AMQP payload of a 16-bit number
in versions 0.8/0.9.

I'll try patching py-amqplib to take frame-max in kwargs, but any other
gotchas you can think of would be appreciated? Would I be better off trying
Tony's PIKA?

Sigurd

2010/2/7 Sigurd Høgsbro <sigurd.hogsbro at museeka.com>

> Hello Matthias,
>
> The below extract from rabbit.log is from a problematic run. It appears the
> python instance running with Windows XP within VirtualBox aborts the
> connection.
>
> The message bodies being sent are 6-25Mb each, which isn't immaterial but
> AFAICT should work.
>
> I used to have immediate and mandatory flags set but I've removed these to
> make the connection as plain vanilla as possible.
>
> Regards,
>
> Sigurd
>
> =INFO REPORT==== 7-Feb-2010::09:55:33 ===
> accepted TCP connection on 0.0.0.0:5672 from 192.168.66.61:54000
>
> =INFO REPORT==== 7-Feb-2010::09:55:33 ===
> starting TCP connection <0.809.5> from 192.168.66.61:54000
>
> =INFO REPORT==== 7-Feb-2010::09:55:51 ===
> accepted TCP connection on 0.0.0.0:5672 from 127.0.0.1:47539
>
> =INFO REPORT==== 7-Feb-2010::09:55:51 ===
> starting TCP connection <0.835.5> from 127.0.0.1:47539
>
> =INFO REPORT==== 7-Feb-2010::09:55:51 ===
> accepted TCP connection on 0.0.0.0:5672 from 127.0.0.1:47540
>
> =INFO REPORT==== 7-Feb-2010::09:55:51 ===
> starting TCP connection <0.841.5> from 127.0.0.1:47540
>
> =WARNING REPORT==== 7-Feb-2010::09:56:35 ===
> exception on TCP connection <0.835.5> from 127.0.0.1:47539
> connection_closed_abruptly
>
> =INFO REPORT==== 7-Feb-2010::09:56:35 ===
>  closing TCP connection <0.835.5> from 127.0.0.1:47539
>
> =WARNING REPORT==== 7-Feb-2010::09:56:35 ===
> exception on TCP connection <0.841.5> from 127.0.0.1:47540
> connection_closed_abruptly
>
> =INFO REPORT==== 7-Feb-2010::09:56:35 ===
> closing TCP connection <0.841.5> from 127.0.0.1:47540
>
> 2010/2/6 Matthias Radestock <matthias at lshift.net>
>
>> Sigurd,
>>
>>
>> Sigurd Høgsbro wrote:
>>
>>> when used in anger sending the response [...] fails with:
>>>
>>> [Errno 10054] An existing connection was forcibly closed by the remote
>>> host
>>>
>>
>> Is there anything unusual in the server logs (rabbit.log and
>> rabbit-sasl.log)?
>>
>>
>> Regards,
>>
>> Matthias.
>>
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20100208/23b56e7a/attachment.htm