Hi Monks! I want to watch different databases with AnyEvent as described on http://www.bzerk.org/documents/postgresperl/. Example works fine agains singe database but not with AnyEvent. Here me testing code
sub start_listen{
my $db_base = DB::Base->new($config{database});
my $connection_strings = $db_base->get_connection_strings();
if( $connection_strings ){
my $dbh;
for( @{$connection_strings} ){
$dbh = $db_base->get_connection(@{$_});
push @dbhs, $dbh;
# print "@{$_}[0] ($dbh->{pg_socket})\n";
# 1. send listen command for each database
print "LISTEN request command send to DB: @{$_}[0]\n";
# 2. create hash to find with database send NOTIFY %[ sock
+et => dbh ]
my $watcher; $watcher = AnyEvent->io(
fh => $dbh->{pg_socket},
poll => "r",
cb => sub{
print "TEST\n";
my $fh = shift;
while(<$fh>){
print STDOUT $_;
}
}
);
}
}
if( @dbhs ){ print "Now we are listen for " . @dbhs . " connectio
+n(s)!\n"; }
else { print "Nothing to listen!\n"; }
};
I need your advice!
-
Are you posting in the right place? Check out Where do I post X? to know for sure.
-
Posts may use any of the Perl Monks Approved HTML tags. Currently these include the following:
<code> <a> <b> <big>
<blockquote> <br /> <dd>
<dl> <dt> <em> <font>
<h1> <h2> <h3> <h4>
<h5> <h6> <hr /> <i>
<li> <nbsp> <ol> <p>
<small> <strike> <strong>
<sub> <sup> <table>
<td> <th> <tr> <tt>
<u> <ul>
-
Snippets of code should be wrapped in
<code> tags not
<pre> tags. In fact, <pre>
tags should generally be avoided. If they must
be used, extreme care should be
taken to ensure that their contents do not
have long lines (<70 chars), in order to prevent
horizontal scrolling (and possible janitor
intervention).
-
Want more info? How to link
or How to display code and escape characters
are good places to start.
|