postpone service notifications per default

lib/Rex/Commands/Service.pm

@@ -158,10 +158,11 @@ sub service {
 
     my $notify = Rex::get_current_connection()->{notify};
     $notify->add(
-      type    => "service",
-      name    => $service,
-      options => {},
-      cb      => sub {
+      type     => "service",
+      name     => $service,
+      postpone => 1,
+      options  => {},
+      cb       => sub {
         my ($option) = shift;
         Rex::Logger::debug("Restarting notified service: $service");
         service( $service => "restart" );

lib/Rex/Notify.pm

@@ -27,16 +27,21 @@ sub new {
 sub add {
   my ( $self, %option ) = @_;
 
-  return if ($self->{__in_notify__});
+  return if ( $self->{__in_notify__} );
 
   if ( exists $self->{__types__}->{ $option{type} }->{ $option{name} } ) {
-    die(  "A resource of the type $option{type} and name $option{name}"
-        . "already exists." );
+    Rex::Logger::debug(
+      "A resource of the type $option{type} and name $option{name}"
+        . "already exists.",
+      "warn"
+    );
+    return;
   }
 
   $self->{__types__}->{ $option{type} }->{ $option{name} } = {
-    options => $option{options},
-    cb      => $option{cb},
+    postpone => $option{postpone} || 0,
+    options  => $option{options},
+    cb       => $option{cb},
   };
 }
 
@@ -47,7 +52,9 @@ sub run {
 
   if ( exists $self->{__types__}->{ $option{type} }
     && exists $self->{__types__}->{ $option{type} }->{ $option{name} }
-    && exists $self->{__types__}->{ $option{type} }->{ $option{name} }->{cb} )
+    && exists $self->{__types__}->{ $option{type} }->{ $option{name} }->{cb}
+    && $self->{__types__}->{ $option{type} }->{ $option{name} }->{postpone} ==
+    0 )
   {
     Rex::Logger::debug("Running notify $option{type} -> $option{name}");