actually start to add logging to Router

[scpubgit/Tak.git] / lib / Tak / Router.pm

diff --git a/lib/Tak/Router.pm b/lib/Tak/Router.pm
index 5c2502b..0aa2060 100644 (file)
--- a/lib/Tak/Router.pm
+++ b/lib/Tak/Router.pm
@@ -2,6 +2,7 @@ package Tak::Router;
 
 use Tak::MetaService;
 use Scalar::Util qw(weaken);
+use Log::Contextual qw(:log);
 use Moo;
 
 has services => (is => 'ro', default => sub { {} });
@@ -23,7 +24,9 @@ sub start_request {
 sub receive {
   my ($self, $target, @payload) = @_;
   return unless $target;
-  return unless my $next = $self->services->{$target};
+  log_debug { "Message received for ${target}" };
+  return log_info { "Discarded message to ${target}" }
+    unless my $next = $self->services->{$target};
   $next->receive(@payload);
 }
 
@@ -42,4 +45,9 @@ sub deregister {
   delete $self->services->{$name}
 }
 
+sub clone_or_self {
+  my ($self) = @_;
+  (ref $self)->new(services => { %{$self->services} });
+}
+
 1;