diff options
Diffstat (limited to 'lib')
-rw-r--r-- | lib/POE/Component/Pg.pm | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/POE/Component/Pg.pm b/lib/POE/Component/Pg.pm index 79687da..e61935b 100644 --- a/lib/POE/Component/Pg.pm +++ b/lib/POE/Component/Pg.pm @@ -166,12 +166,12 @@ sub listen { for my $e (keys %listen) { my($r) = grep $_->[0] == $id && $_->[1] eq $e, @{$_[HEAP]{listen}}; if(!$r) { - push @{$_[HEAP]{listen}}, [ $_[SENDER]->ID, $e, $listen{$e} ]; - $_[KERNEL]->refcount_increment($_[SENDER]->ID, 'P:C:PG'); + push @{$_[HEAP]{listen}}, [ $id, $e, $listen{$e} ]; + $_[KERNEL]->refcount_increment($id, 'P:C:PG'); } else { $r->[2] = $listen{$e}; } - $_[KERNEL]->call($_[SESSION], 'do', query => "LISTEN $e"); + $_[KERNEL]->call($_[SESSION], 'do', "LISTEN $e"); } } @@ -185,7 +185,7 @@ sub unlisten { $_[KERNEL]->refcount_decrement($id, 'P:C:PG') if $rm; !$rm; } @{$_[HEAP]{listen}} ]; - $_[KERNEL]->call($_[SESSION], 'do', query => "UNLISTEN $_->[1]") + $_[KERNEL]->call($_[SESSION], 'do', "UNLISTEN $_->[1]") for (grep { my $i = $_; !grep $_->[1] eq $i, @{$_[HEAP]{listen}} } @u); } |