From 536b29fa6ca68c26012785df5ad6807ce96acc40 Mon Sep 17 00:00:00 2001
From: einhverfr <einhverfr@4979c152-3d1c-0410-bac9-87ea11338e46>
Date: Thu, 13 Dec 2007 18:03:41 +0000
Subject: Correcting issue with process_queue not receiving notifies

git-svn-id: https://ledger-smb.svn.sourceforge.net/svnroot/ledger-smb/trunk@1977 4979c152-3d1c-0410-bac9-87ea11338e46
---
 utils/process_queue/process_queue.pl | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'utils')

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;
 }
-- 
cgit v1.2.3