Merge pull request #7 from kachar/interactive-consumer-fixes

Fix InteractiveConsumer costructor arguments and finish_batch method
dimitri · Jun 22, 2015 · 0535a38 · 0535a38
2 parents 4f9a507 + 6b0e904
commit 0535a38
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/PGQInteractiveConsumer.php b/PGQInteractiveConsumer.php
@@ -24,7 +24,7 @@ abstract class PGQInteractiveConsumer {
   public function __construct($qname, $cname,
 			      $src_constr, $loglevel, $logfile) {
     $this->qname      = $qname;
-    $this->cname      = $qname;
+    $this->cname      = $cname;
     $this->src_constr = $src_constr;
 
     $this->pgcon = pg_connect($this->src_constr);
@@ -158,7 +158,7 @@ protected function next_batch() {
   }
 
   protected function finish_batch($batch_id) {
-    return PGQ::next_batch($this->log, $this->pg_src_con, $batch_id);
+    return PGQ::finish_batch($this->log, $this->pg_src_con, $batch_id);
   }
 
   protected function get_batch_events($batch_id) {
@@ -199,4 +199,4 @@ protected function failed_event_retry($event_id) {
   }
 }
 
-?>
+?>