summaryrefslogtreecommitdiff
path: root/utils
diff options
context:
space:
mode:
Diffstat (limited to 'utils')
-rw-r--r--utils/process_queue/process_queue.pl5
1 files changed, 3 insertions, 2 deletions
diff --git a/utils/process_queue/process_queue.pl b/utils/process_queue/process_queue.pl
index 7c56869a..28401eb6 100644
--- a/utils/process_queue/process_queue.pl
+++ b/utils/process_queue/process_queue.pl
@@ -17,10 +17,9 @@ my $dbh = db_init();
my $sth;
-$dbh->do("LISTEN job_entered");
while (1) { # loop infinitely
if ( $dbh->func('pg_notifies') ) {
- &on_notify;
+ on_notify();
}
sleep $cycle_delay;
}
@@ -85,5 +84,7 @@ sub db_init {
if (!$cycle_delay){
die "No Polling Frequency Set Up!";
}
+ $dbh->do("LISTEN job_entered");
+ $dbh->commit;
return $dbh;
}