view release on metacpan or  search on metacpan

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

        }
        $oob_message->{messages} = \@messages;
        if($use_message and ref $use_message eq 'HASH') {
            $oob_message->{oob_tags}->{message} = {};
            while(my($key,$value) = each %{$use_message}) {
                $oob_message->{oob_tags}->{message}->{$key} = $value
                    if not ref $value;
            }
        }
    }
    if($filter_config and $filter_config->{transit_endpoints}) {
        while(my($transit_name, $transit_def) = each %{$filter_config->{transit_endpoints}}) {
            if($transit_def->{destination}) {
                IPC::Transit::send(
                    qname => $transit_def->{qname},
                    message => $oob_message,
                    destination => $transit_def->{destination}
                );
            } else {
                IPC::Transit::send(
                    qname => $transit_def->{qname},
                    message => $oob_message