[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:56:59 UTC 2013


The following commit has been merged in the master branch:
commit 1677d9c6b8be2b028446f3ae960b032a1c23d28f
Author: Tomas Doran <bobtfish at bobtfish.net>
Date:   Sat May 26 15:25:32 2012 +0100

    Rename

diff --git a/Makefile.PL b/Makefile.PL
index ada05d4..e839ffc 100644
--- a/Makefile.PL
+++ b/Makefile.PL
@@ -5,7 +5,7 @@ use Module::Install::AuthorRequires;
 use Module::Install::AuthorTests;
 use Module::Install::Authority;
 
-all_from 'lib/Log/Stash.pm';
+all_from 'lib/Message/Passing.pm';
 
 license 'AGPL_3';
 authority 'GHENRY';
@@ -33,7 +33,7 @@ author_requires 'Test::Spelling';
 author_tests 't/author';
 
 if ($Module::Install::AUTHOR) {
-    system("pod2text lib/Log/Stash.pm > README")
+    system("pod2text lib/Message/Passing.pm > README")
         and die $!;
 }
 
diff --git a/README b/README
index 2d4493c..78e5581 100644
--- a/README
+++ b/README
@@ -1,5 +1,5 @@
 NAME
-    Log::Stash - a perl subset of Logstash <http://logstash.net>
+    Message::Passing - a perl subset of Logstash <http://logstash.net>
 
 SYNOPSIS
         logstash --input STDIN --output STDOUT
@@ -40,12 +40,14 @@ DESCRIPTION
     Getting started is really easy - you can just use the "logstash" command
     installed by the distribution. If you have a common config that you want
     to repeat, or you want to write your own server which does something
-    more flexible than the normal script allows, then see Log::Stash::DSL.
+    more flexible than the normal script allows, then see
+    Message::Passing::DSL.
 
     To dive straight in, see the documentation for the command line utility
-    logstash, and see the examples in Log::Stash::Manual::Cookbook.
+    logstash, and see the examples in Message::Passing::Manual::Cookbook.
 
-    For more about how the system works, see Log::Stash::Manual::Concepts.
+    For more about how the system works, see
+    Message::Passing::Manual::Concepts.
 
 COMPONENTS
     Below is a non-exhaustive list of components available.
@@ -58,25 +60,26 @@ COMPONENTS
 
     Inputs include:
 
-    Log::Stash::Input::STDIN
-    Log::Stash::Input::ZeroMQ
-    Log::Stash::Input::Test
+    Message::Passing::Input::STDIN
+    Message::Passing::Input::ZeroMQ
+    Message::Passing::Input::Test
 
     You can easily write your own input, just use AnyEvent, and consume
-    Log::Stash::Role::Input.
+    Message::Passing::Role::Input.
 
   FILTER
     Filters can transform a message in any way.
 
     Examples include:
 
-    Log::Stash::Filter::Null - Returns the input unchanged.
-    Log::Stash::Filter::All - Stops any messages it receives from being
-    passed to the output. I.e. literally filters all input out.
-    Log::Stash::Filter::T - Splits the incoming message to multiple outputs.
+    Message::Passing::Filter::Null - Returns the input unchanged.
+    Message::Passing::Filter::All - Stops any messages it receives from
+    being passed to the output. I.e. literally filters all input out.
+    Message::Passing::Filter::T - Splits the incoming message to multiple
+    outputs.
 
     You can easily write your own filter, just consume
-    Log::Stash::Role::Filter.
+    Message::Passing::Role::Filter.
 
     Note that filters can be chained, and a filter can return undef to stop
     a message being passed to the output.
@@ -84,16 +87,17 @@ COMPONENTS
   OUTPUTS
     Outputs send data to somewhere, i.e. they consume messages.
 
-    Log::Stash::Output::STDOUT
-    Log::Stash::Output::AMQP
-    Log::Stash::Output::ZeroMQ
-    Log::Stash::Output::WebHooks
-    Log::Stash::Output::ElasticSearch
-    Log::Stash::Output::Test
+    Message::Passing::Output::STDOUT
+    Message::Passing::Output::AMQP
+    Message::Passing::Output::ZeroMQ
+    Message::Passing::Output::WebHooks
+    Message::Passing::Output::ElasticSearch
+    Message::Passing::Output::Test
 
 SEE ALSO
     Log::Message::Structured - For creating your log messages.
-    Log::Dispatch::Log::Stash - use Log::Stash outputs from Log::Dispatch.
+    Log::Dispatch::Message::Passing - use Message::Passing outputs from
+    Log::Dispatch.
 
 THIS MODULE
     This is a simple MooseX::Getopt script, with one input, one filter and
diff --git a/lib/Log/Stash/Manual.pod b/lib/Log/Stash/Manual.pod
deleted file mode 100644
index 3857f59..0000000
--- a/lib/Log/Stash/Manual.pod
+++ /dev/null
@@ -1,28 +0,0 @@
-=head1 NAME
-
-Log::Stash::Manual - table of contents for Log::Stash documentation
-
-=head1 CONTENTS
-
-=over
-
-=item L<Log::Stash::Manual::Concepts>
-
-How (and why) logstash works.
-
-=item L<Log::Stash::Manual::Cookbook>
-
-Practical examplesof things you can do with the framework.
-
-=item L<Log::Stash::Manual::Components>
-
-Writing your own inputs, filters and outputs.
-
-=back
-
-=head1 AUTHOR & COPYRIGHT
-
-See L<Log::Stash>.
-
-=cut
-
diff --git a/lib/Log/Stash.pm b/lib/Message/Passing.pm
similarity index 75%
rename from lib/Log/Stash.pm
rename to lib/Message/Passing.pm
index 1a10d4e..779acb5 100644
--- a/lib/Log/Stash.pm
+++ b/lib/Message/Passing.pm
@@ -1,17 +1,17 @@
-package Log::Stash;
+package Message::Passing;
 use Moose;
 use Getopt::Long qw(:config pass_through);
 use namespace::autoclean;
 use 5.8.4;
 
-use Log::Stash::DSL;
+use Message::Passing::DSL;
 
 with
     'MooseX::Getopt',
-    'Log::Stash::Role::CLIComponent' => { name => 'input' },
-    'Log::Stash::Role::CLIComponent' => { name => 'output' },
-    'Log::Stash::Role::CLIComponent' => { name => 'filter', default => 'Null' },
-    'Log::Stash::Role::Script';
+    'Message::Passing::Role::CLIComponent' => { name => 'input' },
+    'Message::Passing::Role::CLIComponent' => { name => 'output' },
+    'Message::Passing::Role::CLIComponent' => { name => 'filter', default => 'Null' },
+    'Message::Passing::Role::Script';
 
 our $VERSION = '0.002';
 $VERSION = eval $VERSION;
@@ -41,7 +41,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash - a perl subset of Logstash <http://logstash.net>
+Message::Passing - a perl subset of Logstash <http://logstash.net>
 
 =head1 SYNOPSIS
 
@@ -85,12 +85,12 @@ Getting started is really easy - you can just use the C<logstash>
 command installed by the distribution. If you have a common config
 that you want to repeat, or you want to write your own server
 which does something more flexible than the normal script allows,
-then see L<Log::Stash::DSL>.
+then see L<Message::Passing::DSL>.
 
 To dive straight in, see the documentation for the command line utility
-L<logstash>, and see the examples in L<Log::Stash::Manual::Cookbook>.
+L<logstash>, and see the examples in L<Message::Passing::Manual::Cookbook>.
 
-For more about how the system works, see L<Log::Stash::Manual::Concepts>.
+For more about how the system works, see L<Message::Passing::Manual::Concepts>.
 
 =head1 COMPONENTS
 
@@ -107,16 +107,16 @@ Inputs include:
 
 =over
 
-=item L<Log::Stash::Input::STDIN>
+=item L<Message::Passing::Input::STDIN>
 
-=item L<Log::Stash::Input::ZeroMQ>
+=item L<Message::Passing::Input::ZeroMQ>
 
-=item L<Log::Stash::Input::Test>
+=item L<Message::Passing::Input::Test>
 
 =back
 
 You can easily write your own input, just use L<AnyEvent>, and
-consume L<Log::Stash::Role::Input>.
+consume L<Message::Passing::Role::Input>.
 
 =head2 FILTER
 
@@ -126,16 +126,16 @@ Examples include:
 
 =over
 
-=item L<Log::Stash::Filter::Null> - Returns the input unchanged.
+=item L<Message::Passing::Filter::Null> - Returns the input unchanged.
 
-=item L<Log::Stash::Filter::All> - Stops any messages it receives from being passed to the output. I.e. literally filters all input out.
+=item L<Message::Passing::Filter::All> - Stops any messages it receives from being passed to the output. I.e. literally filters all input out.
 
-=item L<Log::Stash::Filter::T> - Splits the incoming message to multiple outputs.
+=item L<Message::Passing::Filter::T> - Splits the incoming message to multiple outputs.
 
 =back
 
 You can easily write your own filter, just consume
-L<Log::Stash::Role::Filter>.
+L<Message::Passing::Role::Filter>.
 
 Note that filters can be chained, and a filter can return undef to
 stop a message being passed to the output.
@@ -146,17 +146,17 @@ Outputs send data to somewhere, i.e. they consume messages.
 
 =over
 
-=item L<Log::Stash::Output::STDOUT>
+=item L<Message::Passing::Output::STDOUT>
 
-=item L<Log::Stash::Output::AMQP>
+=item L<Message::Passing::Output::AMQP>
 
-=item L<Log::Stash::Output::ZeroMQ>
+=item L<Message::Passing::Output::ZeroMQ>
 
-=item L<Log::Stash::Output::WebHooks>
+=item L<Message::Passing::Output::WebHooks>
 
-=item L<Log::Stash::Output::ElasticSearch>
+=item L<Message::Passing::Output::ElasticSearch>
 
-=item L<Log::Stash::Output::Test>
+=item L<Message::Passing::Output::Test>
 
 =back
 
@@ -166,7 +166,7 @@ Outputs send data to somewhere, i.e. they consume messages.
 
 =item L<Log::Message::Structured> - For creating your log messages.
 
-=item L<Log::Dispatch::Log::Stash> - use Log::Stash outputs from L<Log::Dispatch>.
+=item L<Log::Dispatch::Message::Passing> - use Message::Passing outputs from L<Log::Dispatch>.
 
 =back
 
diff --git a/lib/Log/Stash/DSL.pm b/lib/Message/Passing/DSL.pm
similarity index 88%
rename from lib/Log/Stash/DSL.pm
rename to lib/Message/Passing/DSL.pm
index fb80cb5..3ae5a63 100644
--- a/lib/Log/Stash/DSL.pm
+++ b/lib/Message/Passing/DSL.pm
@@ -1,8 +1,8 @@
-package Log::Stash::DSL;
+package Message::Passing::DSL;
 
 use Moose ();
 use Moose::Exporter;
-use Log::Stash::DSL::Factory;
+use Message::Passing::DSL::Factory;
 use Carp qw/ confess /;
 use Scalar::Util qw/weaken/;
 use AnyEvent;
@@ -22,20 +22,20 @@ sub log_chain (&) {
     if ($FACTORY) {
         confess("Cannot chain within a chain");
     }
-    local $FACTORY = Log::Stash::DSL::Factory->new;
+    local $FACTORY = Message::Passing::DSL::Factory->new;
     $code->();
     my %items = $FACTORY->registry;
     $FACTORY->clear_registry;
     weaken($items{$_}) for
-        grep { does_role($items{$_}, 'Log::Stash::Role::Output') }
+        grep { does_role($items{$_}, 'Message::Passing::Role::Output') }
         keys %items;
     foreach my $name (keys %items) {
         next if $items{$name};
         warn "Unused output or filter $name in chain\n";
     }
     return [
-        grep { !does_role($_, 'Log::Stash::Role::Output') }
-        grep { does_role($_, 'Log::Stash::Role::Input') }
+        grep { !does_role($_, 'Message::Passing::Role::Output') }
+        grep { does_role($_, 'Message::Passing::Role::Input') }
         values %items
     ];
 }
@@ -79,12 +79,12 @@ sub run_log_server {
 
 =head1 NAME
 
-Log::Stash::DSL - An easy way to make chains of logstash objects.
+Message::Passing::DSL - An easy way to make chains of logstash objects.
 
 =head1 SYNOPSIS
 
     package mylogcollectorscript;
-    use Log::Stash::DSL;
+    use Message::Passing::DSL;
 
     with 'MooseX::GetOpt';
 
@@ -114,7 +114,7 @@ Log::Stash::DSL - An easy way to make chains of logstash objects.
 =head1 DESCRIPTION
 
 This module provides a simple to use helper system for writing
-scripts which implement a L<Log::Stash> server, like
+scripts which implement a L<Message::Passing> server, like
 the built in logstash script.
 
 Your script can just be a script, however if it's a class with a
@@ -187,7 +187,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/DSL/Factory.pm b/lib/Message/Passing/DSL/Factory.pm
similarity index 89%
rename from lib/Log/Stash/DSL/Factory.pm
rename to lib/Message/Passing/DSL/Factory.pm
index 4d0bf53..a462aa1 100644
--- a/lib/Log/Stash/DSL/Factory.pm
+++ b/lib/Message/Passing/DSL/Factory.pm
@@ -1,4 +1,4 @@
-package Log::Stash::DSL::Factory;
+package Message::Passing::DSL::Factory;
 use Moose;
 use String::RewritePrefix;
 use namespace::autoclean;
@@ -6,7 +6,7 @@ use namespace::autoclean;
 sub expand_class_name {
     my ($self, $type, $name) = @_;
     String::RewritePrefix->rewrite({
-        '' => 'Log::Stash::' . $type . '::',
+        '' => 'Message::Passing::' . $type . '::',
         '+' => ''
     }, $name);
 }
@@ -68,11 +68,11 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::DSL::Factory - Build a set of logstash chains using symbolic names
+Message::Passing::DSL::Factory - Build a set of logstash chains using symbolic names
 
 =head1 DESCRIPTION
 
-No user serviceable parts inside. See L<Log::Stash::DSL>.
+No user serviceable parts inside. See L<Message::Passing::DSL>.
 
 =head1 SPONSORSHIP
 
@@ -84,7 +84,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Filter/All.pm b/lib/Message/Passing/Filter/All.pm
similarity index 81%
rename from lib/Log/Stash/Filter/All.pm
rename to lib/Message/Passing/Filter/All.pm
index 5b54742..86a1c13 100644
--- a/lib/Log/Stash/Filter/All.pm
+++ b/lib/Message/Passing/Filter/All.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Filter::All;
+package Message::Passing::Filter::All;
 use Moose;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Filter';
+with 'Message::Passing::Role::Filter';
 
 sub filter {
     return;
@@ -13,7 +13,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Filter::All - Filter all messages out.
+Message::Passing::Filter::All - Filter all messages out.
 
 =head1 DESCRIPTION
 
@@ -38,7 +38,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Filter/Delay.pm b/lib/Message/Passing/Filter/Delay.pm
similarity index 85%
rename from lib/Log/Stash/Filter/Delay.pm
rename to lib/Message/Passing/Filter/Delay.pm
index 4ad3adc..26f77d3 100644
--- a/lib/Log/Stash/Filter/Delay.pm
+++ b/lib/Message/Passing/Filter/Delay.pm
@@ -1,12 +1,12 @@
-package Log::Stash::Filter::Delay;
+package Message::Passing::Filter::Delay;
 use Moose;
 use AnyEvent;
 use Scalar::Util qw/ weaken /;
 use namespace::autoclean;
 
 with qw/
-    Log::Stash::Role::Input
-    Log::Stash::Role::Output
+    Message::Passing::Role::Input
+    Message::Passing::Role::Output
 /;
 
 has delay_for => (
@@ -32,7 +32,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Filter::Null - Filter no messages out.
+Message::Passing::Filter::Null - Filter no messages out.
 
 =head1 DESCRIPTION
 
@@ -57,7 +57,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Filter/Key.pm b/lib/Message/Passing/Filter/Key.pm
similarity index 92%
rename from lib/Log/Stash/Filter/Key.pm
rename to lib/Message/Passing/Filter/Key.pm
index d0538bf..0c67a51 100644
--- a/lib/Log/Stash/Filter/Key.pm
+++ b/lib/Message/Passing/Filter/Key.pm
@@ -1,9 +1,9 @@
-package Log::Stash::Filter::Key;
+package Message::Passing::Filter::Key;
 use Moose;
 use Moose::Util::TypeConstraints;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Filter';
+with 'Message::Passing::Role::Filter';
 
 has key => (
     isa => 'Str',
@@ -56,7 +56,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Filter::Key - Filter a subset of messages out.
+Message::Passing::Filter::Key - Filter a subset of messages out.
 
 =head1 DESCRIPTION
 
@@ -93,7 +93,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Filter/Null.pm b/lib/Message/Passing/Filter/Null.pm
similarity index 82%
rename from lib/Log/Stash/Filter/Null.pm
rename to lib/Message/Passing/Filter/Null.pm
index 6f9c40b..7d1607f 100644
--- a/lib/Log/Stash/Filter/Null.pm
+++ b/lib/Message/Passing/Filter/Null.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Filter::Null;
+package Message::Passing::Filter::Null;
 use Moose;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Filter';
+with 'Message::Passing::Role::Filter';
 
 sub filter {
     my ($self, $message) = @_;
@@ -14,7 +14,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Filter::Null - Filter no messages out.
+Message::Passing::Filter::Null - Filter no messages out.
 
 =head1 DESCRIPTION
 
@@ -39,7 +39,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Filter/T.pm b/lib/Message/Passing/Filter/T.pm
similarity index 69%
rename from lib/Log/Stash/Filter/T.pm
rename to lib/Message/Passing/Filter/T.pm
index 1a9731e..0bfe284 100644
--- a/lib/Log/Stash/Filter/T.pm
+++ b/lib/Message/Passing/Filter/T.pm
@@ -1,14 +1,14 @@
-package Log::Stash::Filter::T;
+package Message::Passing::Filter::T;
 use Moose;
 use MooseX::Types::Moose qw/ ArrayRef /;
 use Moose::Util::TypeConstraints;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Input';
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Input';
+with 'Message::Passing::Role::Output';
 
 has '+output_to' => (
-    isa => ArrayRef[role_type('Log::Stash::Role::Output')],
+    isa => ArrayRef[role_type('Message::Passing::Role::Output')],
     is => 'ro',
     required => 1,
 );
@@ -25,20 +25,20 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Filter::T - Send a message stream to multiple outputs.
+Message::Passing::Filter::T - Send a message stream to multiple outputs.
 
 =head1 DESCRIPTION
 
 This filter is used to duplicate a message stream to two or more outputs.
 
 All messages are duplicated to all output streams, so you may want to follow
-this with L<Log::Stash::Filter::Key> to one or more of those streams.
+this with L<Message::Passing::Filter::Key> to one or more of those streams.
 
 =head1 ATTRIBUTES
 
 =head2 output_to
 
-Just like a normal L<Log::Stash::Role::Input> class, except takes an array of outputs.
+Just like a normal L<Message::Passing::Role::Input> class, except takes an array of outputs.
 
 =head1 METHODS
 
@@ -56,7 +56,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Input/FileTail.pm b/lib/Message/Passing/Input/FileTail.pm
similarity index 91%
rename from lib/Log/Stash/Input/FileTail.pm
rename to lib/Message/Passing/Input/FileTail.pm
index de2b065..b6cdb11 100644
--- a/lib/Log/Stash/Input/FileTail.pm
+++ b/lib/Message/Passing/Input/FileTail.pm
@@ -1,11 +1,11 @@
-package Log::Stash::Input::FileTail;
+package Message::Passing::Input::FileTail;
 use Moose;
 use AnyEvent;
 use Try::Tiny;
 use Scalar::Util qw/ weaken /;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Input';
+with 'Message::Passing::Role::Input';
 
 has filename => (
     is => 'ro',
@@ -51,7 +51,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Input::FileTail - File tailing input
+Message::Passing::Input::FileTail - File tailing input
 
 =head1 SYNOPSIS
 
@@ -63,7 +63,7 @@ Log::Stash::Input::FileTail - File tailing input
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 AUTHOR
 
diff --git a/lib/Log/Stash/Input/Null.pm b/lib/Message/Passing/Input/Null.pm
similarity index 85%
rename from lib/Log/Stash/Input/Null.pm
rename to lib/Message/Passing/Input/Null.pm
index 607d645..220c2b3 100644
--- a/lib/Log/Stash/Input/Null.pm
+++ b/lib/Message/Passing/Input/Null.pm
@@ -1,17 +1,17 @@
-package Log::Stash::Input::Null;
+package Message::Passing::Input::Null;
 use Moose;
 use AnyEvent;
 use Try::Tiny;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Input';
+with 'Message::Passing::Role::Input';
 
 __PACKAGE__->meta->make_immutable;
 1;
 
 =head1 NAME
 
-Log::Stash::Input::Null - Null input
+Message::Passing::Input::Null - Null input
 
 =head1 SYNOPSIS
 
@@ -23,7 +23,7 @@ Does nothing (for testing).
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 AUTHOR
 
diff --git a/lib/Log/Stash/Input/STDIN.pm b/lib/Message/Passing/Input/STDIN.pm
similarity index 89%
rename from lib/Log/Stash/Input/STDIN.pm
rename to lib/Message/Passing/Input/STDIN.pm
index 4e3fd12..5ff0541 100644
--- a/lib/Log/Stash/Input/STDIN.pm
+++ b/lib/Message/Passing/Input/STDIN.pm
@@ -1,10 +1,10 @@
-package Log::Stash::Input::STDIN;
+package Message::Passing::Input::STDIN;
 use Moose;
 use AnyEvent;
 use Try::Tiny;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Input';
+with 'Message::Passing::Role::Input';
 
 sub BUILD {
     my $self = shift;
@@ -25,7 +25,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Input::STDIN - STDIN input
+Message::Passing::Input::STDIN - STDIN input
 
 =head1 SYNOPSIS
 
@@ -37,7 +37,7 @@ Log::Stash::Input::STDIN - STDIN input
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 AUTHOR
 
diff --git a/lib/Message/Passing/Manual.pod b/lib/Message/Passing/Manual.pod
new file mode 100644
index 0000000..43242cc
--- /dev/null
+++ b/lib/Message/Passing/Manual.pod
@@ -0,0 +1,28 @@
+=head1 NAME
+
+Message::Passing::Manual - table of contents for Message::Passing documentation
+
+=head1 CONTENTS
+
+=over
+
+=item L<Message::Passing::Manual::Concepts>
+
+How (and why) logstash works.
+
+=item L<Message::Passing::Manual::Cookbook>
+
+Practical examplesof things you can do with the framework.
+
+=item L<Message::Passing::Manual::Components>
+
+Writing your own inputs, filters and outputs.
+
+=back
+
+=head1 AUTHOR & COPYRIGHT
+
+See L<Message::Passing>.
+
+=cut
+
diff --git a/lib/Log/Stash/Manual/Concepts.pod b/lib/Message/Passing/Manual/Concepts.pod
similarity index 80%
rename from lib/Log/Stash/Manual/Concepts.pod
rename to lib/Message/Passing/Manual/Concepts.pod
index 199d5e4..99f6187 100644
--- a/lib/Log/Stash/Manual/Concepts.pod
+++ b/lib/Message/Passing/Manual/Concepts.pod
@@ -1,6 +1,6 @@
 =head1 NAME
 
-Log::Stash::Manual::Concepts - The concepts behind the framework
+Message::Passing::Manual::Concepts - The concepts behind the framework
 
 =head1 DESCRIPTION
 
@@ -22,7 +22,7 @@ as it's only parameter, like this:
 
     $output->consume($message);
     
-Outputs are expected to compose L<Log::Stash::Role::Output>.
+Outputs are expected to compose L<Message::Passing::Role::Output>.
 
 =head2 INPUTS
 
@@ -31,7 +31,7 @@ method on it's output, like this:
 
     $self->output_to->consume($message);
     
-Outputs are expected to compose L<Log::Stash::Role::Input> which provides this attribute, and
+Outputs are expected to compose L<Message::Passing::Role::Input> which provides this attribute, and
 use the C<BUILD> method from Moose to do any work needed to start listening for events.
 
 =head2 FILTER
@@ -39,10 +39,10 @@ use the C<BUILD> method from Moose to do any work needed to start listening for
 A filter is just a combination of an output and input. Some (or all) of the messages consumed
 by the input are sent on to the output.
 
-An optional L<Log::Stash::Role::Filter> is supplied, allowing you to provide a simple filter
+An optional L<Message::Passing::Role::Filter> is supplied, allowing you to provide a simple filter
 method:
 
-    with 'Log::Stash::Role::Filter';
+    with 'Message::Passing::Role::Filter';
     
     sub filter {
         my ($self, $message) = @_;
@@ -52,8 +52,8 @@ method:
 However, if you want or need to, you can however write a filter manually, as:
 
     with qw/
-        Log::Stash::Role::Input
-        Log::Stash::Role::Output
+        Message::Passing::Role::Input
+        Message::Passing::Role::Output
     /;
 
     sub consume {
@@ -69,12 +69,12 @@ an output.
 
 So, this is all pretty easy, and you already know enough to pick up some components and use them! For example:
 
-    use Log::Stash::Input::FileTail;
-    use Log::Stash::Output::STDOUT;
+    use Message::Passing::Input::FileTail;
+    use Message::Passing::Output::STDOUT;
     
-    Log::Stash::Input::FileTail->new(
+    Message::Passing::Input::FileTail->new(
         filename => $ARGV[0],
-        output_to => Log::Stash::Output::STDOUT->new,
+        output_to => Message::Passing::Output::STDOUT->new,
     );
     AnyEvent->condvar->recv; # Enter event loop
 
@@ -87,7 +87,7 @@ you have several inputs being multiplexed into one output, then the code gets ug
 To make it easy to build chains of processing, and your own scripts, a simple DSL is provided.
 The example above becomes:
 
-    use Log::Stash::DSL;
+    use Message::Passing::DSL;
 
     run_log_server log_chain {
         input file => (
@@ -107,17 +107,17 @@ be noted that doing any long operation (non trivial database queries) will block
 no events will be processed. 
 
 In cases such as these, running a pool of worker processes to distribute the blocking jobs is more appropriate,
-and easy to wire up (on one or more hosts). This is documented more fully in L<Log::Stash::Manual::Workers>.
+and easy to wire up (on one or more hosts). This is documented more fully in L<Message::Passing::Manual::Workers>.
 
 =head1 ZeroMQ
 
-L<ZeroMQ> is the recommended transport for logstash messages, and L<Log::Stash::Output::ZeroMQ> is designed to work
+L<ZeroMQ> is the recommended transport for logstash messages, and L<Message::Passing::Output::ZeroMQ> is designed to work
 inside a traditional synchronous application. This means that you can emit messages into ZeroMQ without blocking your
 application, or having to use or run the AnyEvent event loop.
 
 =head1 SEE ALSO
 
-=head2 L<Log::Stash::Manual::Cookbook>
+=head2 L<Message::Passing::Manual::Cookbook>
 
 Recipies for achieving common tasks
 
diff --git a/lib/Log/Stash/Manual/Cookbook.pod b/lib/Message/Passing/Manual/Cookbook.pod
similarity index 91%
rename from lib/Log/Stash/Manual/Cookbook.pod
rename to lib/Message/Passing/Manual/Cookbook.pod
index 01efdf0..9526877 100644
--- a/lib/Log/Stash/Manual/Cookbook.pod
+++ b/lib/Message/Passing/Manual/Cookbook.pod
@@ -1,6 +1,6 @@
 =head1 NAME
 
-Log::Stash::Manual::Cookbook - Common recipies
+Message::Passing::Manual::Cookbook - Common recipies
 
 =head1 Aggregating logs
 
@@ -9,12 +9,12 @@ Log::Stash::Manual::Cookbook - Common recipies
 You can use L<Log::Dispatch>, or any log system which will output into L<Log::Dispatch>.
 
     use Log::Dispatch;
-    use Log::Dispatch::Log::Stash;
-    use Log::Stash::DSL;
+    use Log::Dispatch::Message::Passing;
+    use Message::Passing::DSL;
 
     my $log = Log::Dispatch->new;
 
-    $log->add(Log::Dispatch::Log::Stash->new(
+    $log->add(Log::Dispatch::Message::Passing->new(
         name      => 'myapp_aggregate_log',
         min_level => 'debug',
         output    => log_chain {
diff --git a/lib/Log/Stash/Output/Callback.pm b/lib/Message/Passing/Output/Callback.pm
similarity index 73%
rename from lib/Log/Stash/Output/Callback.pm
rename to lib/Message/Passing/Output/Callback.pm
index dc12b6a..c63aaea 100644
--- a/lib/Log/Stash/Output/Callback.pm
+++ b/lib/Message/Passing/Output/Callback.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Output::Callback;
+package Message::Passing::Output::Callback;
 use Moose;
 use namespace::autoclean;
 
@@ -12,18 +12,18 @@ sub consume {
     $self->cb->($msg);
 }
 
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
 
 __PACKAGE__->meta->make_immutable;
 1;
 
 =head1 NAME
 
-Log::Stash::Output::Callback - Output to call back into your code
+Message::Passing::Output::Callback - Output to call back into your code
 
 =head1 SYNOPSIS
 
-    Log::Stash::Output::Callback->new(
+    Message::Passing::Output::Callback->new(
         cb => sub {
             my $message = shift;
         },
@@ -31,7 +31,7 @@ Log::Stash::Output::Callback - Output to call back into your code
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 SPONSORSHIP
 
@@ -43,7 +43,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Output/File.pm b/lib/Message/Passing/Output/File.pm
similarity index 89%
rename from lib/Log/Stash/Output/File.pm
rename to lib/Message/Passing/Output/File.pm
index aa6a7a4..f806df2 100644
--- a/lib/Log/Stash/Output/File.pm
+++ b/lib/Message/Passing/Output/File.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::File;
+package Message::Passing::Output::File;
 use Moose;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
 
 has filename => (
     isa => 'Str',
@@ -50,7 +50,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Output::File - File output
+Message::Passing::Output::File - File output
 
 =head1 SYNOPSIS
 
@@ -70,7 +70,7 @@ Consumes a message by JSON encoding it and printing it, followed by \n
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 SPONSORSHIP
 
@@ -82,7 +82,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Output/Null.pm b/lib/Message/Passing/Output/Null.pm
similarity index 79%
rename from lib/Log/Stash/Output/Null.pm
rename to lib/Message/Passing/Output/Null.pm
index a655e6a..3a03197 100644
--- a/lib/Log/Stash/Output/Null.pm
+++ b/lib/Message/Passing/Output/Null.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::Null;
+package Message::Passing::Output::Null;
 use Moose;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
 
 sub consume {}
 
@@ -11,7 +11,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Output::Null - /dev/null for logstash messages
+Message::Passing::Output::Null - /dev/null for logstash messages
 
 =head1 SYNOPSIS
 
@@ -32,7 +32,7 @@ Takes a message and discards it silently.
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 SPONSORSHIP
 
@@ -44,7 +44,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Output/STDOUT.pm b/lib/Message/Passing/Output/STDOUT.pm
similarity index 82%
rename from lib/Log/Stash/Output/STDOUT.pm
rename to lib/Message/Passing/Output/STDOUT.pm
index 3e7116f..320947f 100644
--- a/lib/Log/Stash/Output/STDOUT.pm
+++ b/lib/Message/Passing/Output/STDOUT.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::STDOUT;
+package Message::Passing::Output::STDOUT;
 use Moose;
 use namespace::autoclean;
 
-with 'Log::Stash::Role::Output';
+with 'Message::Passing::Role::Output';
 
 sub consume {
     my $self = shift;
@@ -15,7 +15,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Output::STDOUT - STDOUT output
+Message::Passing::Output::STDOUT - STDOUT output
 
 =head1 SYNOPSIS
 
@@ -35,7 +35,7 @@ Consumes a message by JSON encoding it and printing it, followed by \n
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 SPONSORSHIP
 
@@ -47,7 +47,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Output/Test.pm b/lib/Message/Passing/Output/Test.pm
similarity index 83%
rename from lib/Log/Stash/Output/Test.pm
rename to lib/Message/Passing/Output/Test.pm
index b8658f6..5769076 100644
--- a/lib/Log/Stash/Output/Test.pm
+++ b/lib/Message/Passing/Output/Test.pm
@@ -1,8 +1,8 @@
-package Log::Stash::Output::Test;
+package Message::Passing::Output::Test;
 use Moose;
 use namespace::autoclean;
 
-extends 'Log::Stash::Output::Callback';
+extends 'Message::Passing::Output::Callback';
 
 has '+cb' => (
     default => sub { sub {} },
@@ -30,7 +30,7 @@ __PACKAGE__->meta->make_immutable;
 
 =head1 NAME
 
-Log::Stash::Output::Test - Output for use in unit tests
+Message::Passing::Output::Test - Output for use in unit tests
 
 =head1 SYNOPSIS
 
@@ -39,7 +39,7 @@ Log::Stash::Output::Test - Output for use in unit tests
 
 =head1 SEE ALSO
 
-L<Log::Stash>
+L<Message::Passing>
 
 =head1 SPONSORSHIP
 
@@ -51,7 +51,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Role/CLIComponent.pm b/lib/Message/Passing/Role/CLIComponent.pm
similarity index 85%
rename from lib/Log/Stash/Role/CLIComponent.pm
rename to lib/Message/Passing/Role/CLIComponent.pm
index e953321..1335f90 100644
--- a/lib/Log/Stash/Role/CLIComponent.pm
+++ b/lib/Message/Passing/Role/CLIComponent.pm
@@ -1,7 +1,7 @@
-package Log::Stash::Role::CLIComponent;
+package Message::Passing::Role::CLIComponent;
 use MooseX::Role::Parameterized;
 use Moose::Util::TypeConstraints;
-use Log::Stash::Types;
+use Message::Passing::Types;
 use namespace::autoclean;
 
 parameter name => (
@@ -29,7 +29,7 @@ role {
     );
 
     has "${name}_options" => (
-        isa => "Log::Stash::Types::FromJSON",
+        isa => "Message::Passing::Types::FromJSON",
         traits    => ['Hash'],
         default => sub { {} },
         handles => {
diff --git a/lib/Log/Stash/Role/ConnectionManager.pm b/lib/Message/Passing/Role/ConnectionManager.pm
similarity index 91%
rename from lib/Log/Stash/Role/ConnectionManager.pm
rename to lib/Message/Passing/Role/ConnectionManager.pm
index f5a9b31..ffbbdb5 100644
--- a/lib/Log/Stash/Role/ConnectionManager.pm
+++ b/lib/Message/Passing/Role/ConnectionManager.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Role::ConnectionManager;
+package Message::Passing::Role::ConnectionManager;
 use Moose::Role;
 use Scalar::Util qw/ blessed weaken /;
 use namespace::autoclean;
@@ -63,7 +63,7 @@ after _set_connected => sub {
 
 =head1 NAME
 
-Log::Stash::Role::ConnectionManager - A simple manager for inputs and outputs that need to make network connections.
+Message::Passing::Role::ConnectionManager - A simple manager for inputs and outputs that need to make network connections.
 
 =head1 DESCRIPTION
 
@@ -105,7 +105,7 @@ If the manager is already connected when you subscribe, it will immediately call
 C<< connected >> method, if it is not already connected then this will happen at a later point
 once the connection is established.
 
-See L<Log::Stash::Role::HasAConnection> for a role to help with dealing with a connection manager.
+See L<Message::Passing::Role::HasAConnection> for a role to help with dealing with a connection manager.
 
 =head1 ATTRIBUTES
 
diff --git a/lib/Log/Stash/Role/Filter.pm b/lib/Message/Passing/Role/Filter.pm
similarity index 82%
rename from lib/Log/Stash/Role/Filter.pm
rename to lib/Message/Passing/Role/Filter.pm
index ec1ec00..8aff19a 100644
--- a/lib/Log/Stash/Role/Filter.pm
+++ b/lib/Message/Passing/Role/Filter.pm
@@ -1,12 +1,12 @@
-package Log::Stash::Role::Filter;
+package Message::Passing::Role::Filter;
 use Moose::Role;
 use namespace::autoclean;
 
 requires 'filter';
 
 with qw/
-    Log::Stash::Role::Input
-    Log::Stash::Role::Output
+    Message::Passing::Role::Input
+    Message::Passing::Role::Output
 /;
 
 sub consume {
@@ -20,7 +20,7 @@ sub consume {
 
 =head1 NAME
 
-Log::Stash::Mixin::Filter
+Message::Passing::Mixin::Filter
 
 =head1 DESCRIPTION
 
@@ -40,7 +40,7 @@ for filtering out unwanted messages.
 
 =head2 output_to
 
-From L<Log::Stash::Role::Input>.
+From L<Message::Passing::Role::Input>.
 
 =head1 METHODS
 
@@ -54,9 +54,9 @@ In the case where the filter returns a message, outputs the message to the next
 
 =over
 
-=item L<Log::Stash>
+=item L<Message::Passing>
 
-=item L<Log::Stash::Manual::Concepts>
+=item L<Message::Passing::Manual::Concepts>
 
 =back
 
@@ -70,7 +70,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Role/HasAConnection.pm b/lib/Message/Passing/Role/HasAConnection.pm
similarity index 87%
rename from lib/Log/Stash/Role/HasAConnection.pm
rename to lib/Message/Passing/Role/HasAConnection.pm
index 760ae63..879d339 100644
--- a/lib/Log/Stash/Role/HasAConnection.pm
+++ b/lib/Message/Passing/Role/HasAConnection.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Role::HasAConnection;
+package Message::Passing::Role::HasAConnection;
 use Moose::Role;
 use namespace::autoclean;
 
@@ -21,7 +21,7 @@ after BUILD => sub {
 
 =head1 NAME
 
-Log::Stash::Role::HasAConnection - Role for components which have a connection
+Message::Passing::Role::HasAConnection - Role for components which have a connection
 
 =head1 DESCRIPTION
 
@@ -29,7 +29,7 @@ Provides a standard ->connection_manager attribute for inputs or outputs which n
 make a network connection before they can send or receive messages.
 
 The connection manager object is assumed to have the C<< ->subscribe_to_connect >> method
-(from L<Log::Stash::Role::Connection>).
+(from L<Message::Passing::Role::Connection>).
 
 =head1 REQUIRED METHODS
 
diff --git a/lib/Log/Stash/Role/Input.pm b/lib/Message/Passing/Role/Input.pm
similarity index 71%
rename from lib/Log/Stash/Role/Input.pm
rename to lib/Message/Passing/Role/Input.pm
index 2289ac2..4e14de9 100644
--- a/lib/Log/Stash/Role/Input.pm
+++ b/lib/Message/Passing/Role/Input.pm
@@ -1,13 +1,13 @@
-package Log::Stash::Role::Input;
+package Message::Passing::Role::Input;
 use Moose::Role;
 use JSON qw/ from_json /;
-use Log::Stash::Types;
+use Message::Passing::Types;
 use namespace::autoclean;
 
 sub decode { from_json( $_[1], { utf8  => 1 } ) }
 
 has output_to => (
-    isa => 'Log::Stash::Types::Output',
+    isa => 'Message::Passing::Types::Output',
     is => 'ro',
     required => 1,
     coerce => 1,
@@ -17,7 +17,7 @@ has output_to => (
 
 =head1 NAME
 
-Log::Stash::Role::Input
+Message::Passing::Role::Input
 
 =head1 DESCRIPTION
 
@@ -27,7 +27,7 @@ Produces messages.
 
 =head2 output_to
 
-Required, must perform the L<Log::Stash::Role::Output> role.
+Required, must perform the L<Message::Passing::Role::Output> role.
 
 =head1 METHODS
 
@@ -39,9 +39,9 @@ JSON decodes a message supplied as a parameter.
 
 =over
 
-=item L<Log::Stash>
+=item L<Message::Passing>
 
-=item L<Log::Stash::Manual::Concepts>
+=item L<Message::Passing::Manual::Concepts>
 
 =back
 
@@ -55,7 +55,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Role/Output.pm b/lib/Message/Passing/Role/Output.pm
similarity index 76%
rename from lib/Log/Stash/Role/Output.pm
rename to lib/Message/Passing/Role/Output.pm
index a3299c7..f935ff5 100644
--- a/lib/Log/Stash/Role/Output.pm
+++ b/lib/Message/Passing/Role/Output.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Role::Output;
+package Message::Passing::Role::Output;
 use Moose::Role;
 use JSON qw/ to_json /;
 use Scalar::Util qw/ blessed /;
@@ -22,11 +22,11 @@ requires 'consume';
 
 =head1 NAME
 
-Log::Stash::Role::Output - Consumes messages
+Message::Passing::Role::Output - Consumes messages
 
 =head1 DESCRIPTION
 
-This is a role for classes which consumer messages (e.g. a Log::Stash output)
+This is a role for classes which consumer messages (e.g. a Message::Passing output)
 
 =head1 REQUIRED METHODS
 
@@ -38,9 +38,9 @@ Consume a message
 
 =over
 
-=item L<Log::Stash>
+=item L<Message::Passing>
 
-=item L<Log::Stash::Manual::Concepts>
+=item L<Message::Passing::Manual::Concepts>
 
 =back
 
@@ -54,7 +54,7 @@ the SureVoIP API -
 
 =head1 AUTHOR, COPYRIGHT AND LICENSE
 
-See L<Log::Stash>.
+See L<Message::Passing>.
 
 =cut
 
diff --git a/lib/Log/Stash/Role/Script.pm b/lib/Message/Passing/Role/Script.pm
similarity index 95%
rename from lib/Log/Stash/Role/Script.pm
rename to lib/Message/Passing/Role/Script.pm
index fa07074..0baa9ac 100644
--- a/lib/Log/Stash/Role/Script.pm
+++ b/lib/Message/Passing/Role/Script.pm
@@ -1,9 +1,9 @@
-package Log::Stash::Role::Script;
+package Message::Passing::Role::Script;
 use Moose::Role;
 use Getopt::Long qw(:config pass_through);
 use POSIX qw(setuid setgid);
 use Moose::Util::TypeConstraints;
-use Log::Stash::DSL;
+use Message::Passing::DSL;
 use namespace::autoclean;
 
 requires 'build_chain';
@@ -91,7 +91,7 @@ sub start {
 
 =head1 NAME
 
-Log::Stash:Role::Script - Handy role for scripts.
+Message::Passing:Role::Script - Handy role for scripts.
 
 =head1 AUTHOR
 
diff --git a/lib/Log/Stash/Types.pm b/lib/Message/Passing/Types.pm
similarity index 52%
rename from lib/Log/Stash/Types.pm
rename to lib/Message/Passing/Types.pm
index 130feb8..f6faf9f 100644
--- a/lib/Log/Stash/Types.pm
+++ b/lib/Message/Passing/Types.pm
@@ -1,4 +1,4 @@
-package Log::Stash::Types;
+package Message::Passing::Types;
 use MooseX::Types ();
 use Moose::Util::TypeConstraints;
 use JSON ();
@@ -7,11 +7,11 @@ use MooseX::Getopt;
 use Try::Tiny;
 use namespace::autoclean;
 
-role_type 'Log::Stash::Types::Input', { role => 'Log::Stash::Role::Input' };
-role_type 'Log::Stash::Types::Output', { role => 'Log::Stash::Role::Output' };
-role_type 'Log::Stash::Types::Filter', { role => 'Log::Stash::Role::Filter' };
+role_type 'Message::Passing::Types::Input', { role => 'Message::Passing::Role::Input' };
+role_type 'Message::Passing::Types::Output', { role => 'Message::Passing::Role::Output' };
+role_type 'Message::Passing::Types::Filter', { role => 'Message::Passing::Role::Filter' };
 
-coerce 'Log::Stash::Types::Output',
+coerce 'Message::Passing::Types::Output',
     from 'HashRef',
     via {
         my %stuff = %$_;
@@ -20,15 +20,15 @@ coerce 'Log::Stash::Types::Output',
         $class->new(%stuff);
     };
 
-subtype 'Log::Stash::Types::FromJSON',
+subtype 'Message::Passing::Types::FromJSON',
     as "HashRef";
 
-coerce 'Log::Stash::Types::FromJSON',
+coerce 'Message::Passing::Types::FromJSON',
   from NonEmptySimpleStr,
   via { try { JSON->new->relaxed->decode($_) } };
 
 MooseX::Getopt::OptionTypeMap->add_option_type_to_map(
-    'Log::Stash::Types::FromJSON' => '=s'
+    'Message::Passing::Types::FromJSON' => '=s'
 );
 
 1;
diff --git a/script/logstash b/script/logstash
index 8b51a6d..63bfadd 100755
--- a/script/logstash
+++ b/script/logstash
@@ -3,7 +3,7 @@ use FindBin qw/ $Bin /;
 use lib "$Bin/../lib"; # FIXME
 use strict;
 use warnings;
-use Log::Stash;
+use Message::Passing;
 
-Log::Stash->start;
+Message::Passing->start;
 
diff --git a/t/00_compile.t b/t/00_compile.t
index a6cf762..10de0ce 100644
--- a/t/00_compile.t
+++ b/t/00_compile.t
@@ -3,19 +3,19 @@ use warnings;
 
 use Test::More;
 
-use_ok('Log::Stash::Role::HasAConnection');
-use_ok('Log::Stash::Role::ConnectionManager');
-use_ok('Log::Stash');
-use_ok('Log::Stash::Output::STDOUT');
-use_ok('Log::Stash::Input::STDIN');
-use_ok('Log::Stash::Input::FileTail');
-use_ok('Log::Stash::Output::Null');
-use_ok('Log::Stash::Output::Callback');
-use_ok('Log::Stash::Output::Test');
-use_ok('Log::Stash::Output::File');
-use_ok('Log::Stash::Filter::Null');
-use_ok('Log::Stash::Filter::All');
-use_ok('Log::Stash::Filter::Delay');
+use_ok('Message::Passing::Role::HasAConnection');
+use_ok('Message::Passing::Role::ConnectionManager');
+use_ok('Message::Passing');
+use_ok('Message::Passing::Output::STDOUT');
+use_ok('Message::Passing::Input::STDIN');
+use_ok('Message::Passing::Input::FileTail');
+use_ok('Message::Passing::Output::Null');
+use_ok('Message::Passing::Output::Callback');
+use_ok('Message::Passing::Output::Test');
+use_ok('Message::Passing::Output::File');
+use_ok('Message::Passing::Filter::Null');
+use_ok('Message::Passing::Filter::All');
+use_ok('Message::Passing::Filter::Delay');
 
 done_testing;
 
diff --git a/t/author/podcoverage.t b/t/author/podcoverage.t
index 4d703ed..70dacbe 100644
--- a/t/author/podcoverage.t
+++ b/t/author/podcoverage.t
@@ -8,7 +8,7 @@ use Test::Pod::Coverage 1.04;
 my @modules = all_modules;
 our @private = ( 'BUILD' );
 foreach my $module (@modules) {
-    local @private = (@private, 'expand_class_name', 'make') if $module =~ /^Log::Stash::DSL::Factory$/;
+    local @private = (@private, 'expand_class_name', 'make') if $module =~ /^Message::Passing::DSL::Factory$/;
 
     pod_coverage_ok($module, {
         also_private   => \@private,
diff --git a/t/dsl.t b/t/dsl.t
index 5f119ce..46e4ed5 100644
--- a/t/dsl.t
+++ b/t/dsl.t
@@ -2,7 +2,7 @@ use strict;
 use warnings;
 use Test::More;
 
-use Log::Stash::DSL;
+use Message::Passing::DSL;
 
 my $c = log_chain {
         output test => (
@@ -21,10 +21,10 @@ my $c = log_chain {
             output_to => 'null',
         );
 };
-isa_ok $c->[0], 'Log::Stash::Input::STDIN';
-isa_ok $c->[0]->output_to, 'Log::Stash::Filter::Null';
-isa_ok $c->[0]->output_to->output_to, 'Log::Stash::Filter::T';
-isa_ok $c->[0]->output_to->output_to->output_to->[0], 'Log::Stash::Output::Test';
+isa_ok $c->[0], 'Message::Passing::Input::STDIN';
+isa_ok $c->[0]->output_to, 'Message::Passing::Filter::Null';
+isa_ok $c->[0]->output_to->output_to, 'Message::Passing::Filter::T';
+isa_ok $c->[0]->output_to->output_to->output_to->[0], 'Message::Passing::Output::Test';
 $c->[0]->output_to->consume({foo => 'bar'});
 my $test = $c->[0]->output_to->output_to->output_to->[0];
 is $test->message_count, 1;
@@ -46,10 +46,10 @@ $c = log_chain {
 
 is ref($c), 'ARRAY';
 is scalar(@$c), 2;
-isa_ok $c->[0], 'Log::Stash::Input::Null';
-isa_ok $c->[1], 'Log::Stash::Input::STDIN';
-isa_ok $c->[0]->output_to, 'Log::Stash::Output::STDOUT';
-isa_ok $c->[1]->output_to, 'Log::Stash::Output::STDOUT';
+isa_ok $c->[0], 'Message::Passing::Input::Null';
+isa_ok $c->[1], 'Message::Passing::Input::STDIN';
+isa_ok $c->[0]->output_to, 'Message::Passing::Output::STDOUT';
+isa_ok $c->[1]->output_to, 'Message::Passing::Output::STDOUT';
 is $c->[0]->output_to, $c->[1]->output_to;
 
 done_testing;
diff --git a/t/filter.t b/t/filter.t
index a3fd031..c87520f 100644
--- a/t/filter.t
+++ b/t/filter.t
@@ -3,21 +3,21 @@ use warnings;
 use Test::More;
 use Try::Tiny;
 
-use Log::Stash::Filter::Null;
-use Log::Stash::Output::Test;
-use Log::Stash::Filter::All;
-use Log::Stash::Filter::T;
-use Log::Stash::Filter::Key;
-use Log::Stash::Filter::Delay;
+use Message::Passing::Filter::Null;
+use Message::Passing::Output::Test;
+use Message::Passing::Filter::All;
+use Message::Passing::Filter::T;
+use Message::Passing::Filter::Key;
+use Message::Passing::Filter::Delay;
 
 my $called = 0;
 
 my $test;
 my $ob = try {
-    $test = Log::Stash::Output::Test->new(
+    $test = Message::Passing::Output::Test->new(
             cb => sub { $called++ }
     );
-    Log::Stash::Filter::Null->new(output_to => $test)
+    Message::Passing::Filter::Null->new(output_to => $test)
 }
 catch { fail "Failed to construct $_" };
 ok $test;
@@ -36,10 +36,10 @@ is $test->message_count, 0;
 is_deeply [$test->messages], [];
 
 $ob = try {
-    $test = Log::Stash::Output::Test->new(
+    $test = Message::Passing::Output::Test->new(
             cb => sub { $called++ }
     );
-    Log::Stash::Filter::All->new(output_to => $test)
+    Message::Passing::Filter::All->new(output_to => $test)
 }
 catch { fail "Failed to construct $_" };
 ok $test;
@@ -54,13 +54,13 @@ my $called2 = 0;
 
 my $test2;
 $ob = try {
-    $test = Log::Stash::Output::Test->new(
+    $test = Message::Passing::Output::Test->new(
             cb => sub { $called++ }
     );
-    $test2 = Log::Stash::Output::Test->new(
+    $test2 = Message::Passing::Output::Test->new(
             cb => sub { $called2++ }
     );
-    Log::Stash::Filter::T->new(output_to => [$test, $test2])
+    Message::Passing::Filter::T->new(output_to => [$test, $test2])
 }
 catch { fail "Failed to construct $_" };
 ok $test;
@@ -77,10 +77,10 @@ is_deeply [$test2->messages], ['message'];
 is $called2, 1;
 
 $ob = try {
-    $test = Log::Stash::Output::Test->new(
+    $test = Message::Passing::Output::Test->new(
             cb => sub { $called++ }
     );
-    Log::Stash::Filter::Key->new(
+    Message::Passing::Filter::Key->new(
         output_to => $test,
         key => 'foo',
         match => 'bar',
@@ -97,10 +97,10 @@ try { $ob->consume({foo => 'blam', baz => 'quux'}) }
 is_deeply [$test->messages], [{foo => 'bar', baz => 'quux'}];
 
 $ob = try {
-    $test = Log::Stash::Output::Test->new(
+    $test = Message::Passing::Output::Test->new(
             cb => sub { $called++ }
     );
-    Log::Stash::Filter::Key->new(
+    Message::Passing::Filter::Key->new(
         output_to => $test,
         key => 'foo.inner.inner',
         match => 'bar',
@@ -121,8 +121,8 @@ try { $ob->consume({foo => { inner => { inner => 'bar' } }, baz => 'quux'}) }
 is_deeply [$test->messages], [{foo => { inner => { inner => 'bar' } }, baz => 'quux'}];
 
 $ob = try {
-    $test = Log::Stash::Output::Test->new();
-    Log::Stash::Filter::Delay->new(
+    $test = Message::Passing::Output::Test->new();
+    Message::Passing::Filter::Delay->new(
         delay_for => 0.1,
         output_to => $test,
     );
diff --git a/t/input_output_coerce.t b/t/input_output_coerce.t
index c507680..7ea77a0 100644
--- a/t/input_output_coerce.t
+++ b/t/input_output_coerce.t
@@ -2,16 +2,16 @@ use strict;
 use warnings;
 use Test::More 0.88;
 
-use Log::Stash::Input::STDIN;
+use Message::Passing::Input::STDIN;
 
-my $i = Log::Stash::Input::STDIN->new(
+my $i = Message::Passing::Input::STDIN->new(
     output_to => {
-        class => 'Log::Stash::Output::Test',
+        class => 'Message::Passing::Output::Test',
     },
 );
 
 ok $i;
-isa_ok($i->output_to, 'Log::Stash::Output::Test');
+isa_ok($i->output_to, 'Message::Passing::Output::Test');
 
 done_testing;
 
diff --git a/t/logstash_script.t b/t/logstash_script.t
index 34905da..eb6bf49 100644
--- a/t/logstash_script.t
+++ b/t/logstash_script.t
@@ -2,9 +2,9 @@ use strict;
 use warnings;
 use Test::More;
 
-use_ok 'Log::Stash';
+use_ok 'Message::Passing';
 
-my $i = Log::Stash->new(
+my $i = Message::Passing->new(
     input => 'STDIN',
     input_options => '{"foo":"bar"}',
     filter_options => '{"baz":"quux"}',
diff --git a/t/output_encode.t b/t/output_encode.t
index ce42fb1..ff2f925 100644
--- a/t/output_encode.t
+++ b/t/output_encode.t
@@ -11,9 +11,9 @@ use Try::Tiny;
     sub pack { { foo => "bar" } }
 }
 
-use Log::Stash::Output::Test;
+use Message::Passing::Output::Test;
 
-my $test = Log::Stash::Output::Test->new();
+my $test = Message::Passing::Output::Test->new();
 my $packed = $test->encode(bless {}, 'Message');
 
 is $packed, '{"foo":"bar"}';
diff --git a/t/output_null.t b/t/output_null.t
index 096a6c8..fb61dd0 100644
--- a/t/output_null.t
+++ b/t/output_null.t
@@ -3,9 +3,9 @@ use warnings;
 use Test::More;
 use Try::Tiny;
 
-use Log::Stash::Output::Null;
+use Message::Passing::Output::Null;
 
-my $test = try { Log::Stash::Output::Null->new() }
+my $test = try { Message::Passing::Output::Null->new() }
     catch { fail "Failed to construct $_" };
 ok $test;
 
diff --git a/t/output_test.t b/t/output_test.t
index 9b577ea..7f125fa 100644
--- a/t/output_test.t
+++ b/t/output_test.t
@@ -3,11 +3,11 @@ use warnings;
 use Test::More;
 use Try::Tiny;
 
-use Log::Stash::Output::Test;
+use Message::Passing::Output::Test;
 
 my $called = 0;
 
-my $test = try { Log::Stash::Output::Test->new(cb => sub { $called++ }) }
+my $test = try { Message::Passing::Output::Test->new(cb => sub { $called++ }) }
     catch { fail "Failed to construct $_" };
 ok $test;
 
diff --git a/t/role_connectionmanager.t b/t/role_connectionmanager.t
index 51f7b84..343a35b 100644
--- a/t/role_connectionmanager.t
+++ b/t/role_connectionmanager.t
@@ -30,7 +30,7 @@ use Test::More;
     use Scalar::Util qw/ weaken /;
     use namespace::clean -except => 'meta';
 
-    with 'Log::Stash::Role::ConnectionManager';
+    with 'Message::Passing::Role::ConnectionManager';
 
     sub _build_connection {
         my $self = shift;
diff --git a/t/role_hasaconnection.t b/t/role_hasaconnection.t
index f651f3e..e16684e 100644
--- a/t/role_hasaconnection.t
+++ b/t/role_hasaconnection.t
@@ -3,7 +3,7 @@ use warnings;
 use Test::More;
 
 BEGIN {
-    use_ok('Log::Stash::Role::HasAConnection');
+    use_ok('Message::Passing::Role::HasAConnection');
 }
 
 {
@@ -23,7 +23,7 @@ BEGIN {
     use Moose;
     use namespace::clean -except => 'meta';
 
-    with 'Log::Stash::Role::HasAConnection';
+    with 'Message::Passing::Role::HasAConnection';
 
     sub connected {} # Callback API
 

-- 
libmessage-passing-perl Debian packaging



More information about the Pkg-perl-cvs-commits mailing list