[SCM] libmessage-passing-perl Debian packaging branch, master, updated. debian/0.111-3-14-g44f6e88
Tomas Doran
bobtfish at bobtfish.net
Mon May 6 11:57:12 UTC 2013
The following commit has been merged in the master branch:
commit be1a7dc1e060007b31625735446bb83d63300d32
Author: Tomas Doran <bobtfish at bobtfish.net>
Date: Sun Jun 10 17:12:03 2012 +0100
Tweaks
diff --git a/TODO b/TODO
index 93b2157..7299174 100644
--- a/TODO
+++ b/TODO
@@ -7,26 +7,15 @@ Code core/general:
- Global error logging
- Logstash compatibility filter
- Generic blessed object serialize filter
- - Getopt JSON mess fix
- Unify hostname and port parsing between adaptors
Specific adaptors
- AMQP needs a lot of work
- - ZeroMQ needs queue size configuration + docs
- - ZeroMQ needs linger config and docs
- ZeroMQ needs subscribe options
- - PSGI tests
- - PSGI POST
- - PSGI auto apply bufferedstreaming
- - PSGI middleware as seperate step
- - PSGI docs
- STOMP multiple subscriptions
Docs:
- message-passing
- - Pod for the script
-
Message::Passing::Manual::Scripts:
- Write me!
- encoders / decoders
diff --git a/lib/Message/Passing/Filter/Decoder/Null.pm b/lib/Message/Passing/Filter/Decoder/Null.pm
index 57ab068..c1af08d 100644
--- a/lib/Message/Passing/Filter/Decoder/Null.pm
+++ b/lib/Message/Passing/Filter/Decoder/Null.pm
@@ -2,9 +2,7 @@ package Message::Passing::Filter::Decoder::Null;
use Moose;
use namespace::autoclean;
-with 'Message::Passing::Role::Filter';
-
-sub filter { $_[1] }
+extends 'Message::Passing::Filter::Null';
__PACKAGE__->meta->make_immutable;
1;
@@ -29,6 +27,8 @@ Returns message it's passed, verbatim
=over
+=item L<Message::Passing::Filter::Null>
+
=item L<Message::Passing>
=item L<Message::Passing::Manual::Concepts>
diff --git a/lib/Message/Passing/Filter/Encoder/Null.pm b/lib/Message/Passing/Filter/Encoder/Null.pm
index e4f5708..0ad73b3 100644
--- a/lib/Message/Passing/Filter/Encoder/Null.pm
+++ b/lib/Message/Passing/Filter/Encoder/Null.pm
@@ -2,9 +2,7 @@ package Message::Passing::Filter::Encoder::Null;
use Moose;
use namespace::autoclean;
-with 'Message::Passing::Role::Filter';
-
-sub filter { $_[1] }
+extends 'Message::Passing::Filter::Null';
__PACKAGE__->meta->make_immutable;
1;
@@ -29,6 +27,8 @@ Returns message it's passed, verbatim
=over
+=item L<Message::Passing::Filter::Null>
+
=item L<Message::Passing>
=item L<Message::Passing::Manual::Concepts>
diff --git a/lib/Message/Passing/Filter/Null.pm b/lib/Message/Passing/Filter/Null.pm
index 3ca7bd2..7b0066e 100644
--- a/lib/Message/Passing/Filter/Null.pm
+++ b/lib/Message/Passing/Filter/Null.pm
@@ -4,10 +4,7 @@ use namespace::autoclean;
with 'Message::Passing::Role::Filter';
-sub filter {
- my ($self, $message) = @_;
- $message;
-}
+sub filter { $_[1] }
__PACKAGE__->meta->make_immutable;
1;
diff --git a/lib/Message/Passing/Output/STDOUT.pm b/lib/Message/Passing/Output/STDOUT.pm
index dca652a..8d9a4e9 100644
--- a/lib/Message/Passing/Output/STDOUT.pm
+++ b/lib/Message/Passing/Output/STDOUT.pm
@@ -7,7 +7,7 @@ with 'Message::Passing::Role::Output';
sub consume {
my $self = shift;
local $|=1;
- print shift() . "\n";
+ print STDOUT shift() . "\n";
}
__PACKAGE__->meta->make_immutable;
@@ -31,7 +31,7 @@ Output messages to STDOUT
=head2 consume
-Consumes a message by JSON encoding it and printing it, followed by \n
+Consumes a message by printing it, followed by \n
=head1 SEE ALSO
--
libmessage-passing-perl Debian packaging
More information about the Pkg-perl-cvs-commits
mailing list