Hello community,
here is the log from the commit of package perl-Mojo-RabbitMQ-Client for
openSUSE:Factory checked in at 2018-07-28 12:43:03
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Comparing /work/SRC/openSUSE:Factory/perl-Mojo-RabbitMQ-Client (Old)
and /work/SRC/openSUSE:Factory/.perl-Mojo-RabbitMQ-Client.new (New)
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Package is "perl-Mojo-RabbitMQ-Client"
Sat Jul 28 12:43:03 2018 rev:6 rq:625589 version:0.2.0
Changes:
--------
---
/work/SRC/openSUSE:Factory/perl-Mojo-RabbitMQ-Client/perl-Mojo-RabbitMQ-Client.changes
2018-02-20 17:54:34.283553018 +0100
+++
/work/SRC/openSUSE:Factory/.perl-Mojo-RabbitMQ-Client.new/perl-Mojo-RabbitMQ-Client.changes
2018-07-28 12:43:11.660747870 +0200
@@ -1,0 +2,9 @@
+Thu Jul 26 05:36:19 UTC 2018 - [email protected]
+
+- updated to 0.2.0
+ see /usr/share/doc/packages/perl-Mojo-RabbitMQ-Client/Changes
+
+ 0.2.0 2018-07-25T13:23:26Z
+ - Remove internal frame buffer handling, use Net::AMQP #11 (@kraih)
+
+-------------------------------------------------------------------
Old:
----
Mojo-RabbitMQ-Client-0.1.0.tar.gz
New:
----
Mojo-RabbitMQ-Client-0.2.0.tar.gz
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Other differences:
------------------
++++++ perl-Mojo-RabbitMQ-Client.spec ++++++
--- /var/tmp/diff_new_pack.uKFnuh/_old 2018-07-28 12:43:12.040748601 +0200
+++ /var/tmp/diff_new_pack.uKFnuh/_new 2018-07-28 12:43:12.044748608 +0200
@@ -17,7 +17,7 @@
Name: perl-Mojo-RabbitMQ-Client
-Version: 0.1.0
+Version: 0.2.0
Release: 0
%define cpan_name Mojo-RabbitMQ-Client
Summary: Mojo::IOLoop based RabbitMQ client
++++++ Mojo-RabbitMQ-Client-0.1.0.tar.gz -> Mojo-RabbitMQ-Client-0.2.0.tar.gz
++++++
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.1.0/Changes
new/Mojo-RabbitMQ-Client-0.2.0/Changes
--- old/Mojo-RabbitMQ-Client-0.1.0/Changes 2018-02-16 11:15:35.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.2.0/Changes 2018-07-25 15:23:29.000000000
+0200
@@ -1,3 +1,5 @@
+0.2.0 2018-07-25T13:23:26Z
+ - Remove internal frame buffer handling, use Net::AMQP #11 (@kraih)
0.1.0 2018-02-16T10:15:32Z
- Make Mojo::RabbitMQ::Client::Consumer use promises #23 (@christopherraa)
- Fix circular includes by #20 (@christopherraa)
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.1.0/META.json
new/Mojo-RabbitMQ-Client-0.2.0/META.json
--- old/Mojo-RabbitMQ-Client-0.1.0/META.json 2018-02-16 11:15:35.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.2.0/META.json 2018-07-25 15:23:29.000000000
+0200
@@ -59,7 +59,7 @@
"provides" : {
"Mojo::RabbitMQ::Client" : {
"file" : "lib/Mojo/RabbitMQ/Client.pm",
- "version" : "v0.1.0"
+ "version" : "v0.2.0"
},
"Mojo::RabbitMQ::Client::Channel" : {
"file" : "lib/Mojo/RabbitMQ/Client/Channel.pm"
@@ -91,12 +91,13 @@
"web" : "https://github.com/inway/mojo-rabbitmq-client";
}
},
- "version" : "0.1.0",
+ "version" : "0.2.0",
"x_contributors" : [
"Christopher Rasch-Olsen Raa <[email protected]>",
"Patrick Goldmann <[email protected]>",
"Richard Lippmann <[email protected]>",
"Sebastian Podjasek <[email protected]>",
+ "Sebastian Riedel <[email protected]>",
"Stephan Kulow <[email protected]>",
"Vidar Tyldum <[email protected]>"
],
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.1.0/META.yml
new/Mojo-RabbitMQ-Client-0.2.0/META.yml
--- old/Mojo-RabbitMQ-Client-0.1.0/META.yml 2018-02-16 11:15:35.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.2.0/META.yml 2018-07-25 15:23:29.000000000
+0200
@@ -27,7 +27,7 @@
provides:
Mojo::RabbitMQ::Client:
file: lib/Mojo/RabbitMQ/Client.pm
- version: v0.1.0
+ version: v0.2.0
Mojo::RabbitMQ::Client::Channel:
file: lib/Mojo/RabbitMQ/Client/Channel.pm
Mojo::RabbitMQ::Client::Consumer:
@@ -50,12 +50,13 @@
bugtracker: https://github.com/inway/mojo-rabbitmq-client/issues
homepage: https://github.com/inway/mojo-rabbitmq-client
repository: git://github.com/inway/mojo-rabbitmq-client.git
-version: 0.1.0
+version: 0.2.0
x_contributors:
- 'Christopher Rasch-Olsen Raa <[email protected]>'
- 'Patrick Goldmann <[email protected]>'
- 'Richard Lippmann <[email protected]>'
- 'Sebastian Podjasek <[email protected]>'
+ - 'Sebastian Riedel <[email protected]>'
- 'Stephan Kulow <[email protected]>'
- 'Vidar Tyldum <[email protected]>'
x_serialization_backend: 'CPAN::Meta::YAML version 0.018'
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.1.0/inc/Module/AutoInstall.pm
new/Mojo-RabbitMQ-Client-0.2.0/inc/Module/AutoInstall.pm
--- old/Mojo-RabbitMQ-Client-0.1.0/inc/Module/AutoInstall.pm 2018-02-16
11:15:35.000000000 +0100
+++ new/Mojo-RabbitMQ-Client-0.2.0/inc/Module/AutoInstall.pm 2018-07-25
15:23:29.000000000 +0200
@@ -8,7 +8,7 @@
use vars qw{$VERSION};
BEGIN {
- $VERSION = '0.1.0';
+ $VERSION = '0.2.0';
}
# special map on pre-defined feature sets
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/Mojo-RabbitMQ-Client-0.1.0/lib/Mojo/RabbitMQ/Client.pm
new/Mojo-RabbitMQ-Client-0.2.0/lib/Mojo/RabbitMQ/Client.pm
--- old/Mojo-RabbitMQ-Client-0.1.0/lib/Mojo/RabbitMQ/Client.pm 2018-02-16
11:15:35.000000000 +0100
+++ new/Mojo-RabbitMQ-Client-0.2.0/lib/Mojo/RabbitMQ/Client.pm 2018-07-25
15:23:29.000000000 +0200
@@ -20,7 +20,7 @@
require Mojo::RabbitMQ::Client::Consumer;
require Mojo::RabbitMQ::Client::Publisher;
-our $VERSION = "0.1.0";
+our $VERSION = "0.2.0";
use constant DEBUG => $ENV{MOJO_RABBITMQ_DEBUG} // 0;
@@ -273,80 +273,48 @@
sub _read {
my ($self, $id, $chunk) = @_;
- my $chunk_len = length($chunk);
- my $buffer_len = defined $self->{buffer} ? length($self->{buffer}) : 0;
warn "<- @{[dumper $chunk]}" if DEBUG;
-
- if ($chunk_len + $buffer_len > $self->max_buffer_size) {
- $self->{buffer} = '';
- return;
- }
-
- my $data = $self->{buffer} .= $chunk;
-
- if (length($data) < 8) {
- return;
- }
-
- my ($type_id, $channel, $length,) = unpack 'CnN', substr $data, 0, 7;
- if (!defined $type_id || !defined $channel || !defined $length) {
- $self->{buffer} = '';
- return;
- }
-
- if (length($data) < $length) {
- return;
- }
-
- weaken $self;
- $self->_loop->next_tick(sub { $self->_parse_frames });
+ $self->{buffer} .= $chunk;
+ $self->_parse_frames;
return;
}
sub _parse_frames {
my $self = shift;
- my $data = $self->{buffer};
- my ($type_id, $channel, $length,) = unpack 'CnN', substr $data, 0, 7;
+ for my $frame (Net::AMQP->parse_raw_frames(\$self->{buffer})) {
- my $stack = substr $self->{buffer}, 0, $length + 8, '';
-
- my ($frame) = Net::AMQP->parse_raw_frames(\$stack);
-
- if ($frame->isa('Net::AMQP::Frame::Heartbeat')) {
- $self->heartbeat_received(time());
- }
- elsif ($frame->isa('Net::AMQP::Frame::Method')
- and $frame->method_frame->isa('Net::AMQP::Protocol::Connection::Close'))
- {
- $self->is_open(0);
-
- $self->_write_frame(Net::AMQP::Protocol::Connection::CloseOk->new());
- $self->emit(disconnect => "Server side disconnection: "
- . $frame->method_frame->{reply_text});
- }
- elsif ($frame->channel == 0) {
- $self->queue->push($frame);
- }
- else {
- my $channel = $self->channels->{$frame->channel};
- if (defined $channel) {
- $channel->_push_queue_or_consume($frame);
+ if ($frame->isa('Net::AMQP::Frame::Heartbeat')) {
+ $self->heartbeat_received(time());
+ }
+ elsif ($frame->isa('Net::AMQP::Frame::Method')
+ and $frame->method_frame->isa('Net::AMQP::Protocol::Connection::Close'))
+ {
+ $self->is_open(0);
+
+ $self->_write_frame(Net::AMQP::Protocol::Connection::CloseOk->new());
+ $self->emit(disconnect => "Server side disconnection: "
+ . $frame->method_frame->{reply_text});
+ }
+ elsif ($frame->channel == 0) {
+ $self->queue->push($frame);
}
else {
- $self->emit(
- error => "Unknown channel id received: "
- . ($frame->channel // '(undef)'),
- $frame
- );
+ my $channel = $self->channels->{$frame->channel};
+ if (defined $channel) {
+ $channel->_push_queue_or_consume($frame);
+ }
+ else {
+ $self->emit(
+ error => "Unknown channel id received: "
+ . ($frame->channel // '(undef)'),
+ $frame
+ );
+ }
}
}
-
- weaken $self;
- $self->_loop->next_tick(sub { $self->_parse_frames })
- if length($self->{buffer}) >= 8;
}
sub _connect {
