AnyMQ-Pg
view release on metacpan or search on metacpan
inc/Module/Install/Metadata.pm view on Meta::CPAN
# It's in core of perl >= 5.9.3, and should be installed
# as one of the Pod::Simple's prereqs, which is a prereq
# of Pod::Text 3.x (see also below).
$author =~ s{ E<( (\d+) | ([A-Za-z]+) )> }
{
defined $2
? chr($2)
: defined $Pod::Escapes::Name2character_number{$1}
? chr($Pod::Escapes::Name2character_number{$1})
: do {
warn "Unknown escape: E<$1>";
"E<$1>";
};
}gex;
}
elsif (eval "require Pod::Text; 1" && $Pod::Text::VERSION < 3) {
# Pod::Text < 3.0 has yet another mapping table,
# though the table name of 2.x and 1.x are different.
# (1.x is in core of Perl < 5.6, 2.x is in core of
# Perl < 5.9.3)
my $mapping = ($Pod::Text::VERSION < 2)
? \%Pod::Text::HTML_Escapes
: \%Pod::Text::ESCAPES;
$author =~ s{ E<( (\d+) | ([A-Za-z]+) )> }
{
defined $2
? chr($2)
: defined $mapping->{$1}
? $mapping->{$1}
: do {
warn "Unknown escape: E<$1>";
"E<$1>";
};
}gex;
}
else {
$author =~ s{E<lt>}{<}g;
$author =~ s{E<gt>}{>}g;
}
$self->author($author);
} else {
lib/AnyMQ/Trait/Pg.pm view on Meta::CPAN
# publishes notification with $payload on channel
sub notify {
my ($self, @rest) = @_;
my ($channel, $payload, %query_opts) = @rest;
unless ($self->is_connected) {
$self->publish_queue_push(\@rest);
return;
}
my $query = 'NOTIFY "' . $self->_client->dbc->escapeString($channel) . '"';
$query = join(',', $query, $self->_client->dbc->escapeLiteral($payload)) if $payload;
warn $query if $self->debug;
my $qw = $self->_client->push_query(query => $query, %query_opts);
$self->_pg_query_watcher_push($qw);
}
# handles LISTEN/UNLISTEN
sub _push_notif_command {
my ($self, $cmd, $channel, %opts) = @_;
my $query = $cmd . ' "' . $self->_client->dbc->escapeString($channel) . '"';
my $qw = $self->_client->push_query(
query => $query,
%opts
);
warn $query if $self->debug;
$self->_pg_query_watcher_push($qw);
return $qw;
}
sub encode_event {
( run in 0.346 second using v1.01-cache-2.11-cpan-c21f80fb71c )