view release on metacpan or  search on metacpan

lib/App/MultiModule/Task.pm  view on Meta::CPAN

Example:

 $self->emit({something => 'important'});

=cut
sub emit {
    my $self = shift;
    my $message = shift;
    $message->{previous_source} = $message->{source}
        if $message->{source};
    {   my @info = caller(0);
        $message->{source} = $info[0];
        $message->{source} =~ s/.*:://;
    }
    $self->debug('Task: emit: sending to router', message => $message)
        if $self->{debug} > 5;
    $App::MultiModule::Task::emit_counts->{$message->{source}} = 0
        unless $App::MultiModule::Task::emit_counts->{$message->{source}};
    $App::MultiModule::Task::emit_counts->{$message->{source}}++;
    IPC::Transit::send(qname => 'Router', message => $message);
    $self->debug('emit: local transit queue info', local_queues => $IPC::Transit::local_queues)

lib/App/MultiModule/Tasks/OutOfBand.pm  view on Meta::CPAN

        }
    }

    return unless $include_message;
    {   
        $oob_message->{oob_tags} = {};
        my $use_message;
        my @messages = ();
        for (0 .. 10) {
            my $level = $_;
            my @caller = caller($level);
            next unless @caller;
            foreach my $tag (split '::', $caller[0]) {
                $oob_message->{oob_tags}->{$tag} = 1;
            }
            foreach my $tag (split '/', $caller[1]) {
                $oob_message->{oob_tags}->{$tag} = 1;
            }
            $oob_message->{oob_tags}->{'line:' . $caller[2]} = 1;
            $oob_message->{oob_tags}->{$caller[0] . ':' . $caller[2]} = 1;
            foreach my $tag (split '::', $caller[3]) {