SF.net SVN: ledger-smb: [1977] trunk/utils/process_queue/process_queue.pl

[..hidden..]

Revision: 1977
          http://ledger-smb.svn.sourceforge.net/ledger-smb/?rev=1977&view=rev
Author:   einhverfr
Date:     2007-12-13 10:03:41 -0800 (Thu, 13 Dec 2007)

Log Message:
-----------
Correcting issue with process_queue not receiving notifies

Modified Paths:
--------------
    trunk/utils/process_queue/process_queue.pl

Modified: trunk/utils/process_queue/process_queue.pl
===================================================================
--- trunk/utils/process_queue/process_queue.pl	2007-12-13 00:13:37 UTC (rev 1976)
+++ trunk/utils/process_queue/process_queue.pl	2007-12-13 18:03:41 UTC (rev 1977)
@@ -17,10 +17,9 @@
 
 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 @@
     if (!$cycle_delay){
         die "No Polling Frequency Set Up!";
     }
+    $dbh->do("LISTEN job_entered");
+    $dbh->commit;
     return $dbh;
 }


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.