Hello community,
here is the log from the commit of package perl-Mojo-RabbitMQ-Client for
openSUSE:Factory checked in at 2017-02-07 12:09:04
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
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"
Changes:
--------
---
/work/SRC/openSUSE:Factory/perl-Mojo-RabbitMQ-Client/perl-Mojo-RabbitMQ-Client.changes
2017-01-25 23:37:17.460572303 +0100
+++
/work/SRC/openSUSE:Factory/.perl-Mojo-RabbitMQ-Client.new/perl-Mojo-RabbitMQ-Client.changes
2017-02-07 12:09:05.449885784 +0100
@@ -1,0 +2,10 @@
+Tue Jan 31 06:07:08 UTC 2017 - [email protected]
+
+- updated to 0.0.8
+ see /usr/share/doc/packages/perl-Mojo-RabbitMQ-Client/Changes
+
+ 0.0.8 2017-01-30T12:13:18Z
+ - Fix issues with UTF-8 data corruption on SSL sockets PR#7
+ - Drop List::MoreUtils `none` in favour of core List::Util PR#4
+
+-------------------------------------------------------------------
Old:
----
Mojo-RabbitMQ-Client-0.0.7.tar.gz
New:
----
Mojo-RabbitMQ-Client-0.0.8.tar.gz
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Other differences:
------------------
++++++ perl-Mojo-RabbitMQ-Client.spec ++++++
--- /var/tmp/diff_new_pack.bxNxzV/_old 2017-02-07 12:09:05.813834286 +0100
+++ /var/tmp/diff_new_pack.bxNxzV/_new 2017-02-07 12:09:05.813834286 +0100
@@ -1,7 +1,7 @@
#
# spec file for package perl-Mojo-RabbitMQ-Client
#
-# Copyright (c) 2016 SUSE LINUX GmbH, Nuernberg, Germany.
+# Copyright (c) 2017 SUSE LINUX GmbH, Nuernberg, Germany.
#
# All modifications and additions to the file contributed by third parties
# remain the property of their copyright owners, unless otherwise agreed
@@ -17,7 +17,7 @@
Name: perl-Mojo-RabbitMQ-Client
-Version: 0.0.7
+Version: 0.0.8
Release: 0
%define cpan_name Mojo-RabbitMQ-Client
Summary: Mojo::IOLoop based RabbitMQ client
@@ -31,14 +31,14 @@
BuildRequires: perl
BuildRequires: perl-macros
BuildRequires: perl(File::ShareDir)
-BuildRequires: perl(List::MoreUtils)
+BuildRequires: perl(List::Util) >= 1.33
BuildRequires: perl(Module::Build::Tiny) >= 0.035
BuildRequires: perl(Mojolicious) >= 6.10
BuildRequires: perl(Net::AMQP) >= 0.06
BuildRequires: perl(Test::Exception) >= 0.430000
BuildRequires: perl(Test::More) >= 0.98
Requires: perl(File::ShareDir)
-Requires: perl(List::MoreUtils)
+Requires: perl(List::Util) >= 1.33
Requires: perl(Mojolicious) >= 6.10
Requires: perl(Net::AMQP) >= 0.06
%{perl_requires}
++++++ Mojo-RabbitMQ-Client-0.0.7.tar.gz -> Mojo-RabbitMQ-Client-0.0.8.tar.gz
++++++
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.0.7/Changes
new/Mojo-RabbitMQ-Client-0.0.8/Changes
--- old/Mojo-RabbitMQ-Client-0.0.7/Changes 2016-12-02 21:52:18.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/Changes 2017-01-30 13:13:48.000000000
+0100
@@ -1,3 +1,6 @@
+0.0.8 2017-01-30T12:13:18Z
+ - Fix issues with UTF-8 data corruption on SSL sockets PR#7
+ - Drop List::MoreUtils `none` in favour of core List::Util PR#4
0.0.7 2016-12-02T20:52:17Z
- Fix missing dependencies
0.0.6 2016-11-24T00:45:01Z
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.0.7/META.json
new/Mojo-RabbitMQ-Client-0.0.8/META.json
--- old/Mojo-RabbitMQ-Client-0.0.7/META.json 2016-12-02 21:52:18.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/META.json 2017-01-30 13:13:48.000000000
+0100
@@ -43,10 +43,10 @@
"runtime" : {
"requires" : {
"File::ShareDir" : "0",
- "List::MoreUtils" : "0",
+ "List::Util" : "1.33",
"Mojolicious" : "6.10",
"Net::AMQP" : "0.06",
- "perl" : "5.008001"
+ "perl" : "5.010"
}
},
"test" : {
@@ -59,7 +59,7 @@
"provides" : {
"Mojo::RabbitMQ::Client" : {
"file" : "lib/Mojo/RabbitMQ/Client.pm",
- "version" : "v0.0.7"
+ "version" : "v0.0.8"
},
"Mojo::RabbitMQ::Client::Channel" : {
"file" : "lib/Mojo/RabbitMQ/Client/Channel.pm"
@@ -91,9 +91,10 @@
"web" : "https://github.com/inway/mojo-rabbitmq-client";
}
},
- "version" : "0.0.7",
+ "version" : "0.0.8",
"x_contributors" : [
"Vidar Tyldum <[email protected]>",
+ "Stephan Kulow <[email protected]>",
"Sebastian Podjasek <[email protected]>"
],
"x_serialization_backend" : "JSON::PP version 2.27300"
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.0.7/META.yml
new/Mojo-RabbitMQ-Client-0.0.8/META.yml
--- old/Mojo-RabbitMQ-Client-0.0.7/META.yml 2016-12-02 21:52:18.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/META.yml 2017-01-30 13:13:48.000000000
+0100
@@ -27,7 +27,7 @@
provides:
Mojo::RabbitMQ::Client:
file: lib/Mojo/RabbitMQ/Client.pm
- version: v0.0.7
+ version: v0.0.8
Mojo::RabbitMQ::Client::Channel:
file: lib/Mojo/RabbitMQ/Client/Channel.pm
Mojo::RabbitMQ::Client::Consumer:
@@ -42,16 +42,17 @@
file: lib/Mojo/RabbitMQ/Client/Publisher.pm
requires:
File::ShareDir: '0'
- List::MoreUtils: '0'
+ List::Util: '1.33'
Mojolicious: '6.10'
Net::AMQP: '0.06'
- perl: '5.008001'
+ perl: '5.010'
resources:
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.0.7
+version: 0.0.8
x_contributors:
- 'Vidar Tyldum <[email protected]>'
+ - 'Stephan Kulow <[email protected]>'
- 'Sebastian Podjasek <[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.0.7/cpanfile
new/Mojo-RabbitMQ-Client-0.0.8/cpanfile
--- old/Mojo-RabbitMQ-Client-0.0.7/cpanfile 2016-12-02 21:52:18.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/cpanfile 2017-01-30 13:13:48.000000000
+0100
@@ -1,8 +1,8 @@
-requires 'perl', '5.008001';
+requires 'perl', '5.010';
requires 'Mojolicious', '6.10';
requires 'Net::AMQP', '0.06';
requires 'File::ShareDir';
-requires 'List::MoreUtils';
+requires 'List::Util', '1.33';
requires 'File::ShareDir';
on 'test' => sub {
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.0.7/inc/Module/AutoInstall.pm
new/Mojo-RabbitMQ-Client-0.0.8/inc/Module/AutoInstall.pm
--- old/Mojo-RabbitMQ-Client-0.0.7/inc/Module/AutoInstall.pm 2016-12-02
21:52:18.000000000 +0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/inc/Module/AutoInstall.pm 2017-01-30
13:13:48.000000000 +0100
@@ -8,7 +8,7 @@
use vars qw{$VERSION};
BEGIN {
- $VERSION = '0.0.7';
+ $VERSION = '0.0.8';
}
# special map on pre-defined feature sets
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/Mojo-RabbitMQ-Client-0.0.7/lib/Mojo/RabbitMQ/Client/Method.pm
new/Mojo-RabbitMQ-Client-0.0.8/lib/Mojo/RabbitMQ/Client/Method.pm
--- old/Mojo-RabbitMQ-Client-0.0.7/lib/Mojo/RabbitMQ/Client/Method.pm
2016-12-02 21:52:18.000000000 +0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/lib/Mojo/RabbitMQ/Client/Method.pm
2017-01-30 13:13:48.000000000 +0100
@@ -80,11 +80,11 @@
=head2 message
-Can be emmited by consumption & get methods.
+Can be emitted by consumption & get methods.
=head2 empty
-Can be emmited by get method, when no messages are available on queue.
+Can be emitted by get method, when no messages are available on queue.
=head1 ATTRIBUTES
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/Mojo-RabbitMQ-Client-0.0.7/lib/Mojo/RabbitMQ/Client.pm
new/Mojo-RabbitMQ-Client-0.0.8/lib/Mojo/RabbitMQ/Client.pm
--- old/Mojo-RabbitMQ-Client-0.0.7/lib/Mojo/RabbitMQ/Client.pm 2016-12-02
21:52:18.000000000 +0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/lib/Mojo/RabbitMQ/Client.pm 2017-01-30
13:13:48.000000000 +0100
@@ -4,7 +4,7 @@
use Mojo::URL;
use Mojo::Home;
use Mojo::IOLoop;
-use List::MoreUtils qw(none);
+use List::Util qw(none);
use File::Basename 'dirname';
use File::ShareDir qw(dist_file);
@@ -16,7 +16,7 @@
use Mojo::RabbitMQ::Client::LocalQueue;
use Mojo::RabbitMQ::Client::Publisher;
-our $VERSION = "0.0.7";
+our $VERSION = "0.0.8";
use constant DEBUG => $ENV{MOJO_RABBITMQ_DEBUG} // 0;
@@ -454,6 +454,7 @@
my $id = shift @_;
my $frame = shift @_;
+ utf8::downgrade($frame);
$self->_loop->stream($id)->write($frame)
if defined $self->_loop->stream($id);
}
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Mojo-RabbitMQ-Client-0.0.7/xt/server.t
new/Mojo-RabbitMQ-Client-0.0.8/xt/server.t
--- old/Mojo-RabbitMQ-Client-0.0.7/xt/server.t 2016-12-02 21:52:18.000000000
+0100
+++ new/Mojo-RabbitMQ-Client-0.0.8/xt/server.t 2017-01-30 13:13:48.000000000
+0100
@@ -1,8 +1,18 @@
use Test::More tests => 12;
-use Test::Exception;
BEGIN { use_ok 'Mojo::RabbitMQ::Client' }
+sub failure {
+ my ($test, $details) = @_;
+ fail($test);
+ diag("Details: " . $details) if $details;
+ Mojo::IOLoop->stop;
+}
+
+my $run_id = time();
+my $exchange_name = 'mrc_test_' . $run_id;
+my $queue_name = 'mrc_test_queue' . $run_id;
+
my $amqp
= Mojo::RabbitMQ::Client->new(
url => ($ENV{MOJO_RABBITMQ_URL} || 'rabbitmq://guest:[email protected]:5672/')
@@ -10,11 +20,11 @@
$amqp->ioloop->timer( # Global test timeout
10 => sub {
- $amqp->ioloop->stop;
+ failure('Test timeout');
}
);
-$amqp->catch(sub { fail('Connection or other server errors');
$amqp->ioloop->stop; });
+$amqp->catch(sub { failure('Connection or other server errors') });
$amqp->on(connect => sub { pass('Connected to server') });
$amqp->on(
open => sub {
@@ -30,77 +40,51 @@
pass('Channel opened');
my $exchange = $channel->declare_exchange(
- exchange => 'test',
+ exchange => $exchange_name,
type => 'topic',
auto_delete => 1,
);
- $exchange->catch(
- sub {
- fail('Failed to declare exchange');
- $amqp->ioloop->stop;
- }
- );
+ $exchange->catch(sub { failure('Failed to declare exchange') });
$exchange->on(
success => sub {
pass('Exchange declared');
- my $queue = $channel->declare_queue(
- queue => 'test_queue',
- auto_delete => 1,
- );
- $queue->catch(
- sub {
- fail('Failed to declare queue');
- $amqp->ioloop->stop;
- }
- );
+ my $queue = $channel->declare_queue(queue => $queue_name,
+ auto_delete => 1,);
+ $queue->catch(sub { failure('Failed to declare queue') });
$queue->on(
success => sub {
pass('Queue declared');
my $bind = $channel->bind_queue(
- exchange => 'test',
- queue => 'test_queue',
- routing_key => 'test_queue',
- );
- $bind->catch(
- sub {
- fail('Failed to bind queue');
- $amqp->ioloop->stop;
- }
+ exchange => $exchange_name,
+ queue => $queue_name,
+ routing_key => $queue_name,
);
+ $bind->catch(sub { failure('Failed to bind queue') });
$bind->on(
success => sub {
pass('Queue bound');
my $publish = $channel->publish(
- exchange => 'test',
- routing_key => 'test_queue',
+ exchange => $exchange_name,
+ routing_key => $queue_name,
body => 'Test message',
mandatory => 0,
immediate => 0,
header => {}
);
- $publish->catch(
- sub {
- fail('Message not published');
- $amqp->ioloop->stop;
- }
- );
+ $publish->catch(sub { failure('Message not published') });
$publish->on(
success => sub {
pass('Message published');
}
);
- $publish->on(
- return => sub {
- fail('Message returned');
- $amqp->ioloop->stop;
- }
+ $publish->on(return => sub { failure('Message returned') }
);
$publish->deliver();
- my $consumer = $channel->consume(queue => 'test_queue',);
+ my $consumer = $channel->consume(queue => $queue_name,);
$consumer->on(
success => sub {
pass('Subscribed to queue');
@@ -112,12 +96,7 @@
$amqp->close;
}
);
- $consumer->catch(
- sub {
- fail('Subscription failed');
- $amqp->ioloop->stop;
- }
- );
+ $consumer->catch(sub { failure('Subscription failed') });
$consumer->deliver;
}
);
@@ -130,14 +109,15 @@
$exchange->deliver();
}
);
- $channel->on(close => sub { fail('Channel closed'); $amqp->ioloop->stop;
});
- $channel->catch(sub { fail('Channel not opened'); $amqp->ioloop->stop; });
+ $channel->on(close =>
+ sub { failure('Channel closed', $_[1]->method_frame->reply_text) });
+ $channel->catch(sub { failure('Channel not opened') });
$self->open_channel($channel);
}
);
-$amqp->on(close => sub { pass('Connection closed'); });
-$amqp->on(disconnect => sub { pass('Disconnected'); $amqp->ioloop->stop; });
+$amqp->on(close => sub { pass('Connection closed') });
+$amqp->on(disconnect => sub { pass('Disconnected'); Mojo::IOLoop->stop });
$amqp->connect();
-$amqp->ioloop->start;
+Mojo::IOLoop->start unless Mojo::IOLoop->is_running;
