Net--RabbitMQ

Net--RabbitMQ copied to clipboard

Process exit when lost connection

1

Hello. there is a bug. example code: ``` perl my $queue = Net::RabbitMQ->new(); $queue->connect( .... ); $queue->channel_open(1); while (1) { my $result = $queue->publish( 1, ... ); print $result ....

zpl

net_rabbitmq_get drops messages if amqp_data_in_buffer is not ready

1

internally internal_recv uses amqp_data_in_buffer correctly handling where large messages may not be in the buffer yet. This patch skips the unneeded call in net_rabbitmq_get. internal_recv amqp_simple_wait_frame wait_frame_inner amqp_data_in_buffer

dmarkham

Upgrade to rabbitmq-c-fb6fca832fd2

3

I haved upgraded Net::RabbitMQ to rabbitmq-c-fb6fca832fd2 and got rid of a segmentation fault in https://github.com/omniti-labs/Net--RabbitMQ/issues/13. Unfortunately I have not implemented the features added only to Net::RabbitMQ. So you may merge...

MattiL

bugfix for #79411 Connect with invalid password exits

6

This is a fix for [Bug #79411 for Net--RabbitMQ: Connect with invalid password exits](https://rt.cpan.org/Public/Bug/Display.html?id=79411) The problem was that write was called on closed sockets. That caused SIGPIPE signals that weren't...

pmorch

Recover merged but missing commit that makes client send a heartbeat back whenever it receives one. The original commit is discussed at https://github.com/omniti-labs/Net--RabbitMQ/pull/16. It seems that the pull request was...

vitali-trend

memory leak

2

i have a simple test program, while (1) { my $rv = $mq->recv(); my $packed = $rv->{body}; ``` undef $packed; undef $rv; ``` } The memory usage rises time by...

fanyeren

net_rabbitmq_basic_return increases refcount on the callback passed in, but nothing ever decreases it.

tazle

Hello, using RabbitMQ server 2.7.1 I am getting failures when enabling heartbeat. If I set to, say, 30 seconds, my consumer daemon dies with the following message: ``` Bad frame...

alranel

memory leak in fedora 18 with rabbitmq-c from git bleeding

2

3.6.10-4.fc18.i686 #1 SMP Tue Dec 11 18:24:49 UTC 2012 i686 i686 i386 GNU/Linux gcc: Using built-in specs. COLLECT_GCC=gcc COLLECT_LTO_WRAPPER=/usr/libexec/gcc/i686-redhat-linux/4.7.2/lto-wrapper Target: i686-redhat-linux Configured with: ../configure --prefix=/usr --mandir=/usr/share/man --infodir=/usr/share/info --with-bugurl=http://bugzilla.redhat.com/bugzilla --enable-bootstrap --enable-shared...

fanyeren

Method queue_delete not implemented in XS. I can pull patch if need.

seifer